forked from MemeLabs/overrustlelogs
-
Notifications
You must be signed in to change notification settings - Fork 0
/
message.go
42 lines (33 loc) · 974 Bytes
/
message.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
// Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.
/*
* SOURCE:
* message.avsc
*/
package avro
import (
"github.com/actgardner/gogen-avro/container"
"io"
)
type Message struct {
Time int64
Channel string
Nick string
Message string
}
func DeserializeMessage(r io.Reader) (*Message, error) {
return readMessage(r)
}
func NewMessageWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error) {
str := &Message{}
return container.NewWriter(writer, codec, recordsPerBlock, str.Schema())
}
func NewMessage() *Message {
v := &Message{}
return v
}
func (r *Message) Schema() string {
return "{\"fields\":[{\"name\":\"Time\",\"type\":\"long\"},{\"name\":\"Channel\",\"type\":\"string\"},{\"name\":\"Nick\",\"type\":\"string\"},{\"name\":\"Message\",\"type\":\"string\"}],\"name\":\"message\",\"type\":\"record\"}"
}
func (r *Message) Serialize(w io.Writer) error {
return writeMessage(r, w)
}