spec

Documentation

Index

• func RegisterGoetheServer(s *grpc.Server, srv GoetheServer)
• type Cursor
  • func (*Cursor) Descriptor() ([]byte, []int)
  • func (m *Cursor) GetConsumer() string
  • func (m *Cursor) GetCurrentEvent() *Event
  • func (m *Cursor) GetTopic() *Topic
  • func (*Cursor) ProtoMessage()
  • func (m *Cursor) Reset()
  • func (m *Cursor) String() string
  • func (m *Cursor) XXX_DiscardUnknown()
  • func (m *Cursor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Cursor) XXX_Merge(src proto.Message)
  • func (m *Cursor) XXX_Size() int
  • func (m *Cursor) XXX_Unmarshal(b []byte) error
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (m *Event) GetId() string
  • func (m *Event) GetPayload() []byte
  • func (m *Event) GetTopic() *Topic
  • func (*Event) ProtoMessage()
  • func (m *Event) Reset()
  • func (m *Event) String() string
  • func (m *Event) XXX_DiscardUnknown()
  • func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Event) XXX_Merge(src proto.Message)
  • func (m *Event) XXX_Size() int
  • func (m *Event) XXX_Unmarshal(b []byte) error
• type GoetheClient
  • func NewGoetheClient(cc *grpc.ClientConn) GoetheClient
• type GoetheServer
• type Goethe_ConsumeClient
• type Goethe_ConsumeServer
• type Topic
  • func (*Topic) Descriptor() ([]byte, []int)
  • func (m *Topic) GetId() string
  • func (*Topic) ProtoMessage()
  • func (m *Topic) Reset()
  • func (m *Topic) String() string
  • func (m *Topic) XXX_DiscardUnknown()
  • func (m *Topic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Topic) XXX_Merge(src proto.Message)
  • func (m *Topic) XXX_Size() int
  • func (m *Topic) XXX_Unmarshal(b []byte) error
• type UnimplementedGoetheServer
  • func (*UnimplementedGoetheServer) Consume(srv Goethe_ConsumeServer) error
  • func (*UnimplementedGoetheServer) Produce(ctx context.Context, req *Event) (*Event, error)

Functions

func RegisterGoetheServer

func RegisterGoetheServer(s *grpc.Server, srv GoetheServer)

Types

type Cursor

type Cursor struct {
	Topic                *Topic   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Consumer             string   `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
	CurrentEvent         *Event   `protobuf:"bytes,3,opt,name=current_event,json=currentEvent,proto3" json:"current_event,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Cursor) Descriptor

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

func (*Cursor) GetConsumer

func (m *Cursor) GetConsumer() string

func (*Cursor) GetCurrentEvent

func (m *Cursor) GetCurrentEvent() *Event

func (*Cursor) GetTopic

func (m *Cursor) GetTopic() *Topic

func (*Cursor) ProtoMessage

func (*Cursor) ProtoMessage()

func (*Cursor) Reset

func (m *Cursor) Reset()

func (*Cursor) String

func (m *Cursor) String() string

func (*Cursor) XXX_DiscardUnknown

func (m *Cursor) XXX_DiscardUnknown()

func (*Cursor) XXX_Marshal

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

func (*Cursor) XXX_Merge

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

func (*Cursor) XXX_Size

func (m *Cursor) XXX_Size() int

func (*Cursor) XXX_Unmarshal

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

type Event

type Event struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic                *Topic   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload              []byte   `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Event) Descriptor

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

func (*Event) GetId

func (m *Event) GetId() string

func (*Event) GetPayload

func (m *Event) GetPayload() []byte

func (*Event) GetTopic

func (m *Event) GetTopic() *Topic

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 GoetheClient

type GoetheClient interface {
	Produce(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Event, error)
	Consume(ctx context.Context, opts ...grpc.CallOption) (Goethe_ConsumeClient, error)
}

GoetheClient is the client API for Goethe service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGoetheClient

func NewGoetheClient(cc *grpc.ClientConn) GoetheClient

type GoetheServer

type GoetheServer interface {
	Produce(context.Context, *Event) (*Event, error)
	Consume(Goethe_ConsumeServer) error
}

GoetheServer is the server API for Goethe service.

type Goethe_ConsumeClient

type Goethe_ConsumeClient interface {
	Send(*Cursor) error
	Recv() (*Cursor, error)
	grpc.ClientStream
}

type Goethe_ConsumeServer

type Goethe_ConsumeServer interface {
	Send(*Cursor) error
	Recv() (*Cursor, error)
	grpc.ServerStream
}

type Topic

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

func (*Topic) Descriptor

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

func (*Topic) GetId

func (m *Topic) GetId() string

func (*Topic) ProtoMessage

func (*Topic) ProtoMessage()

func (*Topic) Reset

func (m *Topic) Reset()

func (*Topic) String

func (m *Topic) String() string

func (*Topic) XXX_DiscardUnknown

func (m *Topic) XXX_DiscardUnknown()

func (*Topic) XXX_Marshal

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

func (*Topic) XXX_Merge

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

func (*Topic) XXX_Size

func (m *Topic) XXX_Size() int

func (*Topic) XXX_Unmarshal

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

type UnimplementedGoetheServer

type UnimplementedGoetheServer struct {
}

UnimplementedGoetheServer can be embedded to have forward compatible implementations.

func (*UnimplementedGoetheServer) Consume

func (*UnimplementedGoetheServer) Consume(srv Goethe_ConsumeServer) error

func (*UnimplementedGoetheServer) Produce

func (*UnimplementedGoetheServer) Produce(ctx context.Context, req *Event) (*Event, error)