README
¶
Vinna - Message passing service over gRPC
Vinna is a Go implementation of a "kafka" like message passing service that uses gRPC for its streaming communications
Documentation
¶
Index ¶
- Variables
- func StartVinnaServer()
- type Vinna
- func (v Vinna) Add(_ context.Context, msg *pb.Message) (*pb.Success, error)
- func (v Vinna) Consume(cr *pb.ConsumeRequest, stream pb.Vinna_ConsumeServer) error
- func (v Vinna) NewTopic(_ context.Context, tp *pb.Topic) (*pb.TopicCreated, error)
- func (v Vinna) Produce(stream pb.Vinna_ProduceServer) error
- func (v Vinna) Take(_ context.Context, req *pb.MessageRequest) (*pb.Message, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrTopicAlreadyExists is the error if the topic already exists ErrTopicAlreadyExists = errors.New("topic already exists") // ErrTopicDoesNotExist is returned if the topic doesnt exist ErrTopicDoesNotExist = errors.New("topic does not exist") )
Functions ¶
Types ¶
type Vinna ¶
type Vinna struct {
// contains filtered or unexported fields
}
Vinna is the implementation of the vinna service
func (Vinna) Consume ¶
func (v Vinna) Consume(cr *pb.ConsumeRequest, stream pb.Vinna_ConsumeServer) error
Consume will be the service endpoint for client side consuming
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.