vinna

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 New() 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)

Variables

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

func StartVinnaServer

func StartVinnaServer()

StartVinnaServer will create our grpc service

Types

type Vinna

type Vinna struct {
	// contains filtered or unexported fields
}

Vinna is the implementation of the vinna service

func New

func New() Vinna

New will initialize and return a new vinna service structure

func (Vinna) Add

func (v Vinna) Add(_ context.Context, msg *pb.Message) (*pb.Success, error)

Add will add things into 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

func (Vinna) NewTopic

func (v Vinna) NewTopic(_ context.Context, tp *pb.Topic) (*pb.TopicCreated, error)

NewTopic will create a topic to pump data into

func (Vinna) Produce

func (v Vinna) Produce(stream pb.Vinna_ProduceServer) error

Produce will open a stream for client side message sending

func (Vinna) Take

func (v Vinna) Take(_ context.Context, req *pb.MessageRequest) (*pb.Message, error)

Take will take things from the vinna service