gravity

Documentation

Overview

Package gravity is a generated protocol buffer package.

It is generated from these files:

gravity/gravity.proto

It has these top-level messages:

PutReq
PutResp
FlushTaskPart
FlushTask

Index

• func RegisterGravityServiceServer(s *grpc.Server, srv GravityServiceServer)
• type FlushTask
  • func (*FlushTask) Descriptor() ([]byte, []int)
  • func (m *FlushTask) GetParts() []*FlushTaskPart
  • func (m *FlushTask) GetPayload() []*blackhole.Payload
  • func (m *FlushTask) GetSpanContext() *stellar.SpanContext
  • func (m *FlushTask) GetStrategy() *blackhole.Strategy
  • func (m *FlushTask) GetTaskKey() string
  • func (*FlushTask) ProtoMessage()
  • func (m *FlushTask) Reset()
  • func (m *FlushTask) String() string
• type FlushTaskPart
  • func (*FlushTaskPart) Descriptor() ([]byte, []int)
  • func (m *FlushTaskPart) GetNodes() []string
  • func (*FlushTaskPart) ProtoMessage()
  • func (m *FlushTaskPart) Reset()
  • func (m *FlushTaskPart) String() string
• type GravityServiceClient
  • func NewGravityServiceClient(cc *grpc.ClientConn) GravityServiceClient
• type GravityServiceServer
• type PutReq
  • func (*PutReq) Descriptor() ([]byte, []int)
  • func (m *PutReq) GetKey() string
  • func (m *PutReq) GetTask() *celestial.MutateReq
  • func (m *PutReq) GetTaskKey() string
  • func (*PutReq) ProtoMessage()
  • func (m *PutReq) Reset()
  • func (m *PutReq) String() string
• type PutResp
  • func (*PutResp) Descriptor() ([]byte, []int)
  • func (m *PutResp) GetToken() string
  • func (*PutResp) ProtoMessage()
  • func (m *PutResp) Reset()
  • func (m *PutResp) String() string

Functions

func RegisterGravityServiceServer

func RegisterGravityServiceServer(s *grpc.Server, srv GravityServiceServer)

Types

type FlushTask

type FlushTask struct {
	Parts       []*FlushTaskPart     `protobuf:"bytes,1,rep,name=parts" json:"parts,omitempty"`
	Payload     []*blackhole.Payload `protobuf:"bytes,2,rep,name=payload" json:"payload,omitempty"`
	Strategy    *blackhole.Strategy  `protobuf:"bytes,3,opt,name=strategy" json:"strategy,omitempty"`
	TaskKey     string               `protobuf:"bytes,4,opt,name=taskKey" json:"taskKey,omitempty"`
	SpanContext *stellar.SpanContext `protobuf:"bytes,5,opt,name=spanContext" json:"spanContext,omitempty"`
}

func (*FlushTask) Descriptor

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

func (*FlushTask) GetParts

func (m *FlushTask) GetParts() []*FlushTaskPart

func (*FlushTask) GetPayload

func (m *FlushTask) GetPayload() []*blackhole.Payload

func (*FlushTask) GetSpanContext

func (m *FlushTask) GetSpanContext() *stellar.SpanContext

func (*FlushTask) GetStrategy

func (m *FlushTask) GetStrategy() *blackhole.Strategy

func (*FlushTask) GetTaskKey

func (m *FlushTask) GetTaskKey() string

func (*FlushTask) ProtoMessage

func (*FlushTask) ProtoMessage()

func (*FlushTask) Reset

func (m *FlushTask) Reset()

func (*FlushTask) String

func (m *FlushTask) String() string

type FlushTaskPart

type FlushTaskPart struct {
	Nodes []string `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

func (*FlushTaskPart) Descriptor

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

func (*FlushTaskPart) GetNodes

func (m *FlushTaskPart) GetNodes() []string

func (*FlushTaskPart) ProtoMessage

func (*FlushTaskPart) ProtoMessage()

func (*FlushTaskPart) Reset

func (m *FlushTaskPart) Reset()

func (*FlushTaskPart) String

func (m *FlushTaskPart) String() string

type GravityServiceClient

type GravityServiceClient interface {
	PutTask(ctx context.Context, in *PutReq, opts ...grpc.CallOption) (*PutResp, error)
}

func NewGravityServiceClient

func NewGravityServiceClient(cc *grpc.ClientConn) GravityServiceClient

type GravityServiceServer

type GravityServiceServer interface {
	PutTask(context.Context, *PutReq) (*PutResp, error)
}

type PutReq

type PutReq struct {
	Key     string               `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Task    *celestial.MutateReq `protobuf:"bytes,2,opt,name=task" json:"task,omitempty"`
	TaskKey string               `protobuf:"bytes,3,opt,name=taskKey" json:"taskKey,omitempty"`
}

func (*PutReq) Descriptor

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

func (*PutReq) GetKey

func (m *PutReq) GetKey() string

func (*PutReq) GetTask

func (m *PutReq) GetTask() *celestial.MutateReq

func (*PutReq) GetTaskKey

func (m *PutReq) GetTaskKey() string

func (*PutReq) ProtoMessage

func (*PutReq) ProtoMessage()

func (*PutReq) Reset

func (m *PutReq) Reset()

func (*PutReq) String

func (m *PutReq) String() string

type PutResp

type PutResp struct {
	Token string `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
}

func (*PutResp) Descriptor

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

func (*PutResp) GetToken

func (m *PutResp) GetToken() string

func (*PutResp) ProtoMessage

func (*PutResp) ProtoMessage()

func (*PutResp) Reset

func (m *PutResp) Reset()

func (*PutResp) String

func (m *PutResp) String() string