grpc

Documentation

Overview

Package grpc is a generated protocol buffer package.

It is generated from these files:

grpc.proto

It has these top-level messages:

ChangeSet
ReadRequest
ReadResponse
WatchRequest
WatchResponse

Index

• func RegisterSourceServer(s *grpc1.Server, srv SourceServer)
• type ChangeSet
  • func (*ChangeSet) Descriptor() ([]byte, []int)
  • func (m *ChangeSet) GetChecksum() string
  • func (m *ChangeSet) GetData() []byte
  • func (m *ChangeSet) GetFormat() string
  • func (m *ChangeSet) GetSource() string
  • func (m *ChangeSet) GetTimestamp() int64
  • func (*ChangeSet) ProtoMessage()
  • func (m *ChangeSet) Reset()
  • func (m *ChangeSet) String() string
• type ReadRequest
  • func (*ReadRequest) Descriptor() ([]byte, []int)
  • func (m *ReadRequest) GetPath() string
  • func (*ReadRequest) ProtoMessage()
  • func (m *ReadRequest) Reset()
  • func (m *ReadRequest) String() string
• type ReadResponse
  • func (*ReadResponse) Descriptor() ([]byte, []int)
  • func (m *ReadResponse) GetChangeSet() *ChangeSet
  • func (*ReadResponse) ProtoMessage()
  • func (m *ReadResponse) Reset()
  • func (m *ReadResponse) String() string
• type SourceClient
  • func NewSourceClient(cc *grpc1.ClientConn) SourceClient
• type SourceServer
• type Source_WatchClient
• type Source_WatchServer
• type WatchRequest
  • func (*WatchRequest) Descriptor() ([]byte, []int)
  • func (m *WatchRequest) GetPath() string
  • func (*WatchRequest) ProtoMessage()
  • func (m *WatchRequest) Reset()
  • func (m *WatchRequest) String() string
• type WatchResponse
  • func (*WatchResponse) Descriptor() ([]byte, []int)
  • func (m *WatchResponse) GetChangeSet() *ChangeSet
  • func (*WatchResponse) ProtoMessage()
  • func (m *WatchResponse) Reset()
  • func (m *WatchResponse) String() string

Functions

func RegisterSourceServer

func RegisterSourceServer(s *grpc1.Server, srv SourceServer)

Types

type ChangeSet

type ChangeSet struct {
	Data      []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Checksum  string `protobuf:"bytes,2,opt,name=checksum" json:"checksum,omitempty"`
	Format    string `protobuf:"bytes,3,opt,name=format" json:"format,omitempty"`
	Source    string `protobuf:"bytes,4,opt,name=source" json:"source,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*ChangeSet) Descriptor

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

func (*ChangeSet) GetChecksum

func (m *ChangeSet) GetChecksum() string

func (*ChangeSet) GetData

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

func (*ChangeSet) GetFormat

func (m *ChangeSet) GetFormat() string

func (*ChangeSet) GetSource

func (m *ChangeSet) GetSource() string

func (*ChangeSet) GetTimestamp

func (m *ChangeSet) GetTimestamp() int64

func (*ChangeSet) ProtoMessage

func (*ChangeSet) ProtoMessage()

func (*ChangeSet) Reset

func (m *ChangeSet) Reset()

func (*ChangeSet) String

func (m *ChangeSet) String() string

type ReadRequest

type ReadRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
}

func (*ReadRequest) Descriptor

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

func (*ReadRequest) GetPath

func (m *ReadRequest) GetPath() string

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset

func (m *ReadRequest) Reset()

func (*ReadRequest) String

func (m *ReadRequest) String() string

type ReadResponse

type ReadResponse struct {
	ChangeSet *ChangeSet `protobuf:"bytes,1,opt,name=change_set,json=changeSet" json:"change_set,omitempty"`
}

func (*ReadResponse) Descriptor

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

func (*ReadResponse) GetChangeSet

func (m *ReadResponse) GetChangeSet() *ChangeSet

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset

func (m *ReadResponse) Reset()

func (*ReadResponse) String

func (m *ReadResponse) String() string

type SourceClient

type SourceClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc1.CallOption) (*ReadResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc1.CallOption) (Source_WatchClient, error)
}

func NewSourceClient

func NewSourceClient(cc *grpc1.ClientConn) SourceClient

type SourceServer

type SourceServer interface {
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Watch(*WatchRequest, Source_WatchServer) error
}

type Source_WatchClient

type Source_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc1.ClientStream
}

type Source_WatchServer

type Source_WatchServer interface {
	Send(*WatchResponse) error
	grpc1.ServerStream
}

type WatchRequest

type WatchRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
}

func (*WatchRequest) Descriptor

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

func (*WatchRequest) GetPath

func (m *WatchRequest) GetPath() string

func (*WatchRequest) ProtoMessage

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset

func (m *WatchRequest) Reset()

func (*WatchRequest) String

func (m *WatchRequest) String() string

type WatchResponse

type WatchResponse struct {
	ChangeSet *ChangeSet `protobuf:"bytes,1,opt,name=change_set,json=changeSet" json:"change_set,omitempty"`
}

func (*WatchResponse) Descriptor

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

func (*WatchResponse) GetChangeSet

func (m *WatchResponse) GetChangeSet() *ChangeSet

func (*WatchResponse) ProtoMessage

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset

func (m *WatchResponse) Reset()

func (*WatchResponse) String

func (m *WatchResponse) String() string