ts

type Channel struct {
	Topic string
	// contains filtered or unexported fields
}

type Client struct {
	Host  string
	Token string
	// contains filtered or unexported fields
}

type Event struct {
	Topic   string `protobuf:"bytes,1,opt,name=Topic" json:"Topic,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	Done    bool   `protobuf:"varint,3,opt,name=Done" json:"Done,omitempty"`
}

type EventReply struct {
}

type IngestClient interface {
	StreamEvents(ctx context.Context, opts ...grpc.CallOption) (Ingest_StreamEventsClient, error)
}

type IngestServer interface {
	StreamEvents(Ingest_StreamEventsServer) error
}

type Ingest_StreamEventsClient interface {
	Send(*Event) error
	Recv() (*EventReply, error)
	grpc.ClientStream
}

type Ingest_StreamEventsServer interface {
	Send(*EventReply) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type Register struct {
	Topic string `protobuf:"bytes,1,opt,name=Topic" json:"Topic,omitempty"`
	User  string `protobuf:"bytes,2,opt,name=User" json:"User,omitempty"`
}

type RegisterReply struct {
}

type StreamerClient interface {
	GetStream(ctx context.Context, in *Topic, opts ...grpc.CallOption) (Streamer_GetStreamClient, error)
}

type StreamerServer interface {
	GetStream(*Topic, Streamer_GetStreamServer) error
}

type Streamer_GetStreamClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Streamer_GetStreamServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Topic struct {
	ID       int64  `protobuf:"varint,1,opt,name=ID" json:"ID,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=Name" json:"Name,omitempty"`
	Position int64  `protobuf:"varint,3,opt,name=Position" json:"Position,omitempty"`
	Public   bool   `protobuf:"varint,4,opt,name=Public" json:"Public,omitempty"`
}

type TopicMetadata struct {
	Name   string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Public bool   `protobuf:"varint,2,opt,name=public" json:"public,omitempty"`
}

type TopicsClient interface {
	RegisterTopic(ctx context.Context, in *Register, opts ...grpc.CallOption) (*RegisterReply, error)
	GetTopics(ctx context.Context, in *TopicsReq, opts ...grpc.CallOption) (*TopicsReply, error)
	UpdateTopic(ctx context.Context, in *TopicMetadata, opts ...grpc.CallOption) (*UpdateReply, error)
}

type TopicsReply struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics" json:"topics,omitempty"`
}

type TopicsReq struct {
	Username string `protobuf:"bytes,1,opt,name=Username" json:"Username,omitempty"`
}

type TopicsServer interface {
	RegisterTopic(context.Context, *Register) (*RegisterReply, error)
	GetTopics(context.Context, *TopicsReq) (*TopicsReply, error)
	UpdateTopic(context.Context, *TopicMetadata) (*UpdateReply, error)
}

type UpdateReply struct {
}