gravity_api_pipeline

package
v0.2.15 Latest Latest
Warning

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

 Go to latest Published: May 24, 2021 License: MIT Imports: 3 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateSnapshotReply 

type CreateSnapshotReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSnapshotReply) Descriptor 

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

func (*CreateSnapshotReply) GetReason 

func (m *CreateSnapshotReply) GetReason() string

func (*CreateSnapshotReply) GetSuccess 

func (m *CreateSnapshotReply) GetSuccess() bool

func (*CreateSnapshotReply) ProtoMessage 

func (*CreateSnapshotReply) ProtoMessage()

func (*CreateSnapshotReply) Reset 

func (m *CreateSnapshotReply) Reset()

func (*CreateSnapshotReply) String 

func (m *CreateSnapshotReply) String() string

func (*CreateSnapshotReply) XXX_DiscardUnknown 

func (m *CreateSnapshotReply) XXX_DiscardUnknown()

func (*CreateSnapshotReply) XXX_Marshal 

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

func (*CreateSnapshotReply) XXX_Merge 

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

func (*CreateSnapshotReply) XXX_Size 

func (m *CreateSnapshotReply) XXX_Size() int

func (*CreateSnapshotReply) XXX_Unmarshal 

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

type CreateSnapshotRequest 

type CreateSnapshotRequest struct {
	SnapshotID           string   `protobuf:"bytes,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSnapshotRequest) Descriptor 

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

func (*CreateSnapshotRequest) GetSnapshotID 

func (m *CreateSnapshotRequest) GetSnapshotID() string

func (*CreateSnapshotRequest) ProtoMessage 

func (*CreateSnapshotRequest) ProtoMessage()

func (*CreateSnapshotRequest) Reset 

func (m *CreateSnapshotRequest) Reset()

func (*CreateSnapshotRequest) String 

func (m *CreateSnapshotRequest) String() string

func (*CreateSnapshotRequest) XXX_DiscardUnknown 

func (m *CreateSnapshotRequest) XXX_DiscardUnknown()

func (*CreateSnapshotRequest) XXX_Marshal 

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

func (*CreateSnapshotRequest) XXX_Merge 

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

func (*CreateSnapshotRequest) XXX_Size 

func (m *CreateSnapshotRequest) XXX_Size() int

func (*CreateSnapshotRequest) XXX_Unmarshal 

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

type FetchSnapshotReply 

type FetchSnapshotReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Count                uint64   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	LastKey              []byte   `protobuf:"bytes,4,opt,name=lastKey,proto3" json:"lastKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchSnapshotReply) Descriptor 

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

func (*FetchSnapshotReply) GetCount 

func (m *FetchSnapshotReply) GetCount() uint64

func (*FetchSnapshotReply) GetLastKey 

func (m *FetchSnapshotReply) GetLastKey() []byte

func (*FetchSnapshotReply) GetReason 

func (m *FetchSnapshotReply) GetReason() string

func (*FetchSnapshotReply) GetSuccess 

func (m *FetchSnapshotReply) GetSuccess() bool

func (*FetchSnapshotReply) ProtoMessage 

func (*FetchSnapshotReply) ProtoMessage()

func (*FetchSnapshotReply) Reset 

func (m *FetchSnapshotReply) Reset()

func (*FetchSnapshotReply) String 

func (m *FetchSnapshotReply) String() string

func (*FetchSnapshotReply) XXX_DiscardUnknown 

func (m *FetchSnapshotReply) XXX_DiscardUnknown()

func (*FetchSnapshotReply) XXX_Marshal 

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

func (*FetchSnapshotReply) XXX_Merge 

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

func (*FetchSnapshotReply) XXX_Size 

func (m *FetchSnapshotReply) XXX_Size() int

func (*FetchSnapshotReply) XXX_Unmarshal 

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

type FetchSnapshotRequest 

type FetchSnapshotRequest struct {
	SubscriberID         string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	PipelineID           uint64   `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Offset               uint64   `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Count                int64    `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchSnapshotRequest) Descriptor 

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

func (*FetchSnapshotRequest) GetCount 

func (m *FetchSnapshotRequest) GetCount() int64

func (*FetchSnapshotRequest) GetKey 

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

func (*FetchSnapshotRequest) GetOffset 

func (m *FetchSnapshotRequest) GetOffset() uint64

func (*FetchSnapshotRequest) GetPipelineID added in v0.2.15 

func (m *FetchSnapshotRequest) GetPipelineID() uint64

func (*FetchSnapshotRequest) GetSubscriberID 

func (m *FetchSnapshotRequest) GetSubscriberID() string

func (*FetchSnapshotRequest) ProtoMessage 

func (*FetchSnapshotRequest) ProtoMessage()

func (*FetchSnapshotRequest) Reset 

func (m *FetchSnapshotRequest) Reset()

func (*FetchSnapshotRequest) String 

func (m *FetchSnapshotRequest) String() string

func (*FetchSnapshotRequest) XXX_DiscardUnknown 

func (m *FetchSnapshotRequest) XXX_DiscardUnknown()

func (*FetchSnapshotRequest) XXX_Marshal 

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

func (*FetchSnapshotRequest) XXX_Merge 

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

func (*FetchSnapshotRequest) XXX_Size 

func (m *FetchSnapshotRequest) XXX_Size() int

func (*FetchSnapshotRequest) XXX_Unmarshal 

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

type GetStateReply 

type GetStateReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	LastSeq              uint64   `protobuf:"varint,3,opt,name=lastSeq,proto3" json:"lastSeq,omitempty"`
	Count                uint64   `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateReply) Descriptor 

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

func (*GetStateReply) GetCount 

func (m *GetStateReply) GetCount() uint64

func (*GetStateReply) GetLastSeq 

func (m *GetStateReply) GetLastSeq() uint64

func (*GetStateReply) GetReason 

func (m *GetStateReply) GetReason() string

func (*GetStateReply) GetSuccess 

func (m *GetStateReply) GetSuccess() bool

func (*GetStateReply) ProtoMessage 

func (*GetStateReply) ProtoMessage()

func (*GetStateReply) Reset 

func (m *GetStateReply) Reset()

func (*GetStateReply) String 

func (m *GetStateReply) String() string

func (*GetStateReply) XXX_DiscardUnknown 

func (m *GetStateReply) XXX_DiscardUnknown()

func (*GetStateReply) XXX_Marshal 

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

func (*GetStateReply) XXX_Merge 

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

func (*GetStateReply) XXX_Size 

func (m *GetStateReply) XXX_Size() int

func (*GetStateReply) XXX_Unmarshal 

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

type GetStateRequest 

type GetStateRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateRequest) Descriptor 

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

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) Reset 

func (m *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (m *GetStateRequest) String() string

func (*GetStateRequest) XXX_DiscardUnknown 

func (m *GetStateRequest) XXX_DiscardUnknown()

func (*GetStateRequest) XXX_Marshal 

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

func (*GetStateRequest) XXX_Merge 

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

func (*GetStateRequest) XXX_Size 

func (m *GetStateRequest) XXX_Size() int

func (*GetStateRequest) XXX_Unmarshal 

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

type PipelineReply 

type PipelineReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PipelineReply) Descriptor 

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

func (*PipelineReply) GetReason 

func (m *PipelineReply) GetReason() string

func (*PipelineReply) GetSuccess 

func (m *PipelineReply) GetSuccess() bool

func (*PipelineReply) ProtoMessage 

func (*PipelineReply) ProtoMessage()

func (*PipelineReply) Reset 

func (m *PipelineReply) Reset()

func (*PipelineReply) String 

func (m *PipelineReply) String() string

func (*PipelineReply) XXX_DiscardUnknown 

func (m *PipelineReply) XXX_DiscardUnknown()

func (*PipelineReply) XXX_Marshal 

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

func (*PipelineReply) XXX_Merge 

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

func (*PipelineReply) XXX_Size 

func (m *PipelineReply) XXX_Size() int

func (*PipelineReply) XXX_Unmarshal 

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

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.