Documentation

Index

• Constants
• func NewServer(host string, port int, topology string) *grpc.Server
• type OccServerImpl
  • func (s *OccServerImpl) EventStream(req *pb.EventStreamRequest, srv pb.Occ_EventStreamServer) error
  • func (s *OccServerImpl) GetState(ctx context.Context, req *pb.GetStateRequest) (*pb.GetStateReply, error)
  • func (s *OccServerImpl) StateStream(req *pb.StateStreamRequest, srv pb.Occ_StateStreamServer) error
  • func (s *OccServerImpl) Transition(ctx context.Context, req *pb.TransitionRequest) (*pb.TransitionReply, error)

Constants

const CALL_TIMEOUT = 30 * time.Second

Variables

This section is empty.

Functions

func NewServer

func NewServer(host string, port int, topology string) *grpc.Server

Types

type OccServerImpl

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

func (*OccServerImpl) EventStream

func (s *OccServerImpl) EventStream(req *pb.EventStreamRequest, srv pb.Occ_EventStreamServer) error

FIXME: this is a dummy implementation

func (*OccServerImpl) GetState

func (s *OccServerImpl) GetState(ctx context.Context, req *pb.GetStateRequest) (*pb.GetStateReply, error)

func (*OccServerImpl) StateStream

func (s *OccServerImpl) StateStream(req *pb.StateStreamRequest, srv pb.Occ_StateStreamServer) error

func (*OccServerImpl) Transition

func (s *OccServerImpl) Transition(ctx context.Context, req *pb.TransitionRequest) (*pb.TransitionReply, error)