grpc

Documentation

Index

• type Client
  • func NewClient(address string) (Client, error)
• type Options
  • func (o *Options) Address() string
  • func (o *Options) Bind(fs *flag.FlagSet)
• type Server
  • func NewServer(resultstore db.CalculationResultsStore) *Server
  • func (s *Server) GetData(ctx context.Context, in *proto.GetDataRequest) (*proto.GetDataResponse, error)
  • func (s *Server) StoreData(ctx context.Context, in *proto.StoreRequest) (*proto.StoreResponse, error)

Types

type Client

type Client interface {
	StoreData(parameters map[string]string, results string) (*proto.StoreResponse, error)
	GetData(parameters map[string]string) (*proto.GetDataResponse, error)
	Close() error
}

func NewClient

func NewClient(address string) (Client, error)

NewClient creates a new Client connected to the given address.

type Options

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

func (*Options) Address

func (o *Options) Address() string

func (*Options) Bind

func (o *Options) Bind(fs *flag.FlagSet)

type Server

type Server struct {
	proto.UnimplementedDbServiceServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(resultstore db.CalculationResultsStore) *Server

func (*Server) GetData

func (s *Server) GetData(ctx context.Context, in *proto.GetDataRequest) (*proto.GetDataResponse, error)

func (*Server) StoreData

func (s *Server) StoreData(ctx context.Context, in *proto.StoreRequest) (*proto.StoreResponse, error)