types

package
v0.0.0-...-5cdce85 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2022 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_types_types_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Ack 

type Ack struct {
	NodeId    []byte               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	EventId   []byte               `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func AckUnmarshal 

func AckUnmarshal(m []byte) (Ack, error)

func (*Ack) Descriptor deprecated 

func (*Ack) Descriptor() ([]byte, []int)

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetEventId 

func (x *Ack) GetEventId() []byte

func (*Ack) GetNodeId 

func (x *Ack) GetNodeId() []byte

func (*Ack) GetTimestamp 

func (x *Ack) GetTimestamp() *timestamp.Timestamp

func (Ack) Marshal 

func (a Ack) Marshal() []byte

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

func (x *Ack) ProtoReflect() protoreflect.Message

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) String 

func (x *Ack) String() string

type Announce 

type Announce struct {
	NodeId    []byte               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Addr      string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Port      int32                `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func AnnounceUnmarshal 

func AnnounceUnmarshal(m []byte) (Announce, error)

func (*Announce) Descriptor deprecated 

func (*Announce) Descriptor() ([]byte, []int)

Deprecated: Use Announce.ProtoReflect.Descriptor instead.

func (*Announce) GetAddr 

func (x *Announce) GetAddr() string

func (*Announce) GetNodeId 

func (x *Announce) GetNodeId() []byte

func (*Announce) GetPort 

func (x *Announce) GetPort() int32

func (*Announce) GetTimestamp 

func (x *Announce) GetTimestamp() *timestamp.Timestamp

func (Announce) Marshal 

func (a Announce) Marshal() []byte

func (*Announce) ProtoMessage 

func (*Announce) ProtoMessage()

func (*Announce) ProtoReflect 

func (x *Announce) ProtoReflect() protoreflect.Message

func (*Announce) Reset 

func (x *Announce) Reset()

func (*Announce) String 

func (x *Announce) String() string

type Event 

type Event struct {
	NodeId    []byte               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Id        []byte               `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Key       string               `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte               `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func EventUnmarshal 

func EventUnmarshal(m []byte) (Event, error)

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetId 

func (x *Event) GetId() []byte

func (*Event) GetKey 

func (x *Event) GetKey() string

func (*Event) GetNodeId 

func (x *Event) GetNodeId() []byte

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() *timestamp.Timestamp

func (*Event) GetValue 

func (x *Event) GetValue() []byte

func (Event) Marshal 

func (a Event) Marshal() []byte

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Result 

type Result struct {
	NodeId    []byte               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	EventId   []byte               `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Key       string               `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte               `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func ResultUnmarshal 

func ResultUnmarshal(m []byte) (Result, error)

func (*Result) Descriptor deprecated 

func (*Result) Descriptor() ([]byte, []int)

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetEventId 

func (x *Result) GetEventId() []byte

func (*Result) GetKey 

func (x *Result) GetKey() string

func (*Result) GetNodeId 

func (x *Result) GetNodeId() []byte

func (*Result) GetTimestamp 

func (x *Result) GetTimestamp() *timestamp.Timestamp

func (*Result) GetValue 

func (x *Result) GetValue() []byte

func (Result) Marshal 

func (a Result) Marshal() []byte

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

func (x *Result) ProtoReflect() protoreflect.Message

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

type Time 

type Time struct {
	NodeId    []byte               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func TimeUnmarshal 

func TimeUnmarshal(m []byte) (Time, error)

func (*Time) Descriptor deprecated 

func (*Time) Descriptor() ([]byte, []int)

Deprecated: Use Time.ProtoReflect.Descriptor instead.

func (*Time) GetNodeId 

func (x *Time) GetNodeId() []byte

func (*Time) GetTimestamp 

func (x *Time) GetTimestamp() *timestamp.Timestamp

func (Time) Marshal 

func (a Time) Marshal() []byte

func (*Time) ProtoMessage 

func (*Time) ProtoMessage()

func (*Time) ProtoReflect 

func (x *Time) ProtoReflect() protoreflect.Message

func (*Time) Reset 

func (x *Time) Reset()

func (*Time) String 

func (x *Time) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.