gravity_sdk_types_event

package
v0.0.39 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventPayload_State_name = map[int32]string{
	0: "STATE_NONE",
	1: "STATE_CHUNK_END",
}
View Source 
var EventPayload_State_value = map[string]int32{
	"STATE_NONE":      0,
	"STATE_CHUNK_END": 1,
}
View Source 
var Event_Type_name = map[int32]string{
	0: "TYPE_EVENT",
	1: "TYPE_SNAPSHOT",
	3: "TYPE_SYSTEM",
}
View Source 
var Event_Type_value = map[string]int32{
	"TYPE_EVENT":    0,
	"TYPE_SNAPSHOT": 1,
	"TYPE_SYSTEM":   3,
}
View Source 
var SnapshotInfo_State_name = map[int32]string{
	0: "STATE_NONE",
	1: "STATE_CHUNK_END",
}
View Source 
var SnapshotInfo_State_value = map[string]int32{
	"STATE_NONE":      0,
	"STATE_CHUNK_END": 1,
}
View Source 
var SystemMessage_Type_name = map[int32]string{
	0: "TYPE_WAKE",
}
View Source 
var SystemMessage_Type_value = map[string]int32{
	"TYPE_WAKE": 0,
}

Functions

This section is empty.

Types

type Event 

type Event struct {
	Type                 Event_Type     `protobuf:"varint,1,opt,name=type,proto3,enum=gravity.sdk.types.event.Event_Type" json:"type,omitempty"`
	EventPayload         *EventPayload  `protobuf:"bytes,2,opt,name=eventPayload,proto3" json:"eventPayload,omitempty"`
	SnapshotInfo         *SnapshotInfo  `protobuf:"bytes,3,opt,name=snapshotInfo,proto3" json:"snapshotInfo,omitempty"`
	SystemInfo           *SystemMessage `protobuf:"bytes,4,opt,name=systemInfo,proto3" json:"systemInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetEventPayload added in v0.0.13 

func (m *Event) GetEventPayload() *EventPayload

func (*Event) GetSnapshotInfo added in v0.0.13 

func (m *Event) GetSnapshotInfo() *SnapshotInfo

func (*Event) GetSystemInfo added in v0.0.13 

func (m *Event) GetSystemInfo() *SystemMessage

func (*Event) GetType added in v0.0.10 

func (m *Event) GetType() Event_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventPayload added in v0.0.13 

type EventPayload struct {
	PipelineID           uint64             `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Sequence             uint64             `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Data                 []byte             `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	State                EventPayload_State `protobuf:"varint,4,opt,name=state,proto3,enum=gravity.sdk.types.event.EventPayload_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EventPayload) Descriptor added in v0.0.13 

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

func (*EventPayload) GetData added in v0.0.13 

func (m *EventPayload) GetData() []byte

func (*EventPayload) GetPipelineID added in v0.0.13 

func (m *EventPayload) GetPipelineID() uint64

func (*EventPayload) GetSequence added in v0.0.13 

func (m *EventPayload) GetSequence() uint64

func (*EventPayload) GetState added in v0.0.13 

func (m *EventPayload) GetState() EventPayload_State

func (*EventPayload) ProtoMessage added in v0.0.13 

func (*EventPayload) ProtoMessage()

func (*EventPayload) Reset added in v0.0.13 

func (m *EventPayload) Reset()

func (*EventPayload) String added in v0.0.13 

func (m *EventPayload) String() string

func (*EventPayload) XXX_DiscardUnknown added in v0.0.13 

func (m *EventPayload) XXX_DiscardUnknown()

func (*EventPayload) XXX_Marshal added in v0.0.13 

func (m *EventPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventPayload) XXX_Merge added in v0.0.13 

func (m *EventPayload) XXX_Merge(src proto.Message)

func (*EventPayload) XXX_Size added in v0.0.13 

func (m *EventPayload) XXX_Size() int

func (*EventPayload) XXX_Unmarshal added in v0.0.13 

func (m *EventPayload) XXX_Unmarshal(b []byte) error

type EventPayload_State added in v0.0.13 

type EventPayload_State int32
const (
	EventPayload_STATE_NONE      EventPayload_State = 0
	EventPayload_STATE_CHUNK_END EventPayload_State = 1
)

func (EventPayload_State) EnumDescriptor added in v0.0.13 

func (EventPayload_State) EnumDescriptor() ([]byte, []int)

func (EventPayload_State) String added in v0.0.13 

func (x EventPayload_State) String() string

type Event_Type added in v0.0.10 

type Event_Type int32
const (
	Event_TYPE_EVENT    Event_Type = 0
	Event_TYPE_SNAPSHOT Event_Type = 1
	Event_TYPE_SYSTEM   Event_Type = 3
)

func (Event_Type) EnumDescriptor added in v0.0.10 

func (Event_Type) EnumDescriptor() ([]byte, []int)

func (Event_Type) String added in v0.0.10 

func (x Event_Type) String() string

type SnapshotInfo added in v0.0.13 

type SnapshotInfo struct {
	PipelineID           uint64             `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	SnapshotID           string             `protobuf:"bytes,2,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"`
	Collection           string             `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
	Key                  []byte             `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Data                 []byte             `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	State                SnapshotInfo_State `protobuf:"varint,6,opt,name=state,proto3,enum=gravity.sdk.types.event.SnapshotInfo_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SnapshotInfo) Descriptor added in v0.0.13 

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

func (*SnapshotInfo) GetCollection added in v0.0.13 

func (m *SnapshotInfo) GetCollection() string

func (*SnapshotInfo) GetData added in v0.0.13 

func (m *SnapshotInfo) GetData() []byte

func (*SnapshotInfo) GetKey added in v0.0.13 

func (m *SnapshotInfo) GetKey() []byte

func (*SnapshotInfo) GetPipelineID added in v0.0.13 

func (m *SnapshotInfo) GetPipelineID() uint64

func (*SnapshotInfo) GetSnapshotID added in v0.0.13 

func (m *SnapshotInfo) GetSnapshotID() string

func (*SnapshotInfo) GetState added in v0.0.13 

func (m *SnapshotInfo) GetState() SnapshotInfo_State

func (*SnapshotInfo) ProtoMessage added in v0.0.13 

func (*SnapshotInfo) ProtoMessage()

func (*SnapshotInfo) Reset added in v0.0.13 

func (m *SnapshotInfo) Reset()

func (*SnapshotInfo) String added in v0.0.13 

func (m *SnapshotInfo) String() string

func (*SnapshotInfo) XXX_DiscardUnknown added in v0.0.13 

func (m *SnapshotInfo) XXX_DiscardUnknown()

func (*SnapshotInfo) XXX_Marshal added in v0.0.13 

func (m *SnapshotInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SnapshotInfo) XXX_Merge added in v0.0.13 

func (m *SnapshotInfo) XXX_Merge(src proto.Message)

func (*SnapshotInfo) XXX_Size added in v0.0.13 

func (m *SnapshotInfo) XXX_Size() int

func (*SnapshotInfo) XXX_Unmarshal added in v0.0.13 

func (m *SnapshotInfo) XXX_Unmarshal(b []byte) error

type SnapshotInfo_State added in v0.0.13 

type SnapshotInfo_State int32
const (
	SnapshotInfo_STATE_NONE      SnapshotInfo_State = 0
	SnapshotInfo_STATE_CHUNK_END SnapshotInfo_State = 1
)

func (SnapshotInfo_State) EnumDescriptor added in v0.0.13 

func (SnapshotInfo_State) EnumDescriptor() ([]byte, []int)

func (SnapshotInfo_State) String added in v0.0.13 

func (x SnapshotInfo_State) String() string

type SystemMessage added in v0.0.13 

type SystemMessage struct {
	Type                 SystemMessage_Type          `protobuf:"varint,1,opt,name=type,proto3,enum=gravity.sdk.types.event.SystemMessage_Type" json:"type,omitempty"`
	AwakeMessage         *SystemMessage_AwakeMessage `protobuf:"bytes,2,opt,name=awakeMessage,proto3" json:"awakeMessage,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*SystemMessage) Descriptor added in v0.0.13 

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

func (*SystemMessage) GetAwakeMessage added in v0.0.13 

func (m *SystemMessage) GetAwakeMessage() *SystemMessage_AwakeMessage

func (*SystemMessage) GetType added in v0.0.13 

func (m *SystemMessage) GetType() SystemMessage_Type

func (*SystemMessage) ProtoMessage added in v0.0.13 

func (*SystemMessage) ProtoMessage()

func (*SystemMessage) Reset added in v0.0.13 

func (m *SystemMessage) Reset()

func (*SystemMessage) String added in v0.0.13 

func (m *SystemMessage) String() string

func (*SystemMessage) XXX_DiscardUnknown added in v0.0.13 

func (m *SystemMessage) XXX_DiscardUnknown()

func (*SystemMessage) XXX_Marshal added in v0.0.13 

func (m *SystemMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SystemMessage) XXX_Merge added in v0.0.13 

func (m *SystemMessage) XXX_Merge(src proto.Message)

func (*SystemMessage) XXX_Size added in v0.0.13 

func (m *SystemMessage) XXX_Size() int

func (*SystemMessage) XXX_Unmarshal added in v0.0.13 

func (m *SystemMessage) XXX_Unmarshal(b []byte) error

type SystemMessage_AwakeMessage added in v0.0.13 

type SystemMessage_AwakeMessage struct {
	PipelineID           uint64   `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Sequence             uint64   `protobuf:"varint,2,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SystemMessage_AwakeMessage) Descriptor added in v0.0.13 

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

func (*SystemMessage_AwakeMessage) GetPipelineID added in v0.0.13 

func (m *SystemMessage_AwakeMessage) GetPipelineID() uint64

func (*SystemMessage_AwakeMessage) GetSequence added in v0.0.13 

func (m *SystemMessage_AwakeMessage) GetSequence() uint64

func (*SystemMessage_AwakeMessage) ProtoMessage added in v0.0.13 

func (*SystemMessage_AwakeMessage) ProtoMessage()

func (*SystemMessage_AwakeMessage) Reset added in v0.0.13 

func (m *SystemMessage_AwakeMessage) Reset()

func (*SystemMessage_AwakeMessage) String added in v0.0.13 

func (m *SystemMessage_AwakeMessage) String() string

func (*SystemMessage_AwakeMessage) XXX_DiscardUnknown added in v0.0.13 

func (m *SystemMessage_AwakeMessage) XXX_DiscardUnknown()

func (*SystemMessage_AwakeMessage) XXX_Marshal added in v0.0.13 

func (m *SystemMessage_AwakeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SystemMessage_AwakeMessage) XXX_Merge added in v0.0.13 

func (m *SystemMessage_AwakeMessage) XXX_Merge(src proto.Message)

func (*SystemMessage_AwakeMessage) XXX_Size added in v0.0.13 

func (m *SystemMessage_AwakeMessage) XXX_Size() int

func (*SystemMessage_AwakeMessage) XXX_Unmarshal added in v0.0.13 

func (m *SystemMessage_AwakeMessage) XXX_Unmarshal(b []byte) error

type SystemMessage_Type added in v0.0.13 

type SystemMessage_Type int32
const (
	SystemMessage_TYPE_WAKE SystemMessage_Type = 0
)

func (SystemMessage_Type) EnumDescriptor added in v0.0.13 

func (SystemMessage_Type) EnumDescriptor() ([]byte, []int)

func (SystemMessage_Type) String added in v0.0.13 

func (x SystemMessage_Type) 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.