pb

type ConsumeRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
}

type Message struct {
	Uuid  string `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	Msg   []byte `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
}

type MessageRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	MsgID string `protobuf:"bytes,2,opt,name=msgID" json:"msgID,omitempty"`
}

type ProducerSummary struct {
	MsgCount    int32 `protobuf:"varint,1,opt,name=msgCount" json:"msgCount,omitempty"`
	TopicCount  int32 `protobuf:"varint,2,opt,name=topicCount" json:"topicCount,omitempty"`
	ElapsedTime int32 `protobuf:"varint,3,opt,name=elapsedTime" json:"elapsedTime,omitempty"`
}

type Success struct {
	MsgID   string `protobuf:"bytes,1,opt,name=msgID" json:"msgID,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success" json:"success,omitempty"`
}

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

type TopicCreated struct {
	Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
}

type VinnaClient interface {
	// NewTopic will create a new topic for messages
	NewTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*TopicCreated, error)
	// Add a message to vinna
	Add(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Success, error)
	// Take a message from vinna
	Take(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*Message, error)
	// Produce will open up a production stream of data
	Produce(ctx context.Context, opts ...grpc.CallOption) (Vinna_ProduceClient, error)
	// Consumer will be an endpoint for streaming data to a client side consumer
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (Vinna_ConsumeClient, error)
}

type VinnaServer interface {
	// NewTopic will create a new topic for messages
	NewTopic(context.Context, *Topic) (*TopicCreated, error)
	// Add a message to vinna
	Add(context.Context, *Message) (*Success, error)
	// Take a message from vinna
	Take(context.Context, *MessageRequest) (*Message, error)
	// Produce will open up a production stream of data
	Produce(Vinna_ProduceServer) error
	// Consumer will be an endpoint for streaming data to a client side consumer
	Consume(*ConsumeRequest, Vinna_ConsumeServer) error
}

type Vinna_ConsumeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type Vinna_ConsumeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type Vinna_ProduceClient interface {
	Send(*Message) error
	CloseAndRecv() (*ProducerSummary, error)
	grpc.ClientStream
}

type Vinna_ProduceServer interface {
	SendAndClose(*ProducerSummary) error
	Recv() (*Message, error)
	grpc.ServerStream
}