nopb

Documentation

Index

• type JsonCodec
  • func (*JsonCodec) Marshal(v interface{}) ([]byte, error)
  • func (*JsonCodec) Name() string
  • func (*JsonCodec) Unmarshal(data []byte, v interface{}) error
• type OccClient
  • func NewOccClient(cc *grpc.ClientConn) OccClient

Types

type JsonCodec

type JsonCodec struct{}

Satisfies interface grpc.encoding.Codec

func (*JsonCodec) Marshal

func (*JsonCodec) Marshal(v interface{}) ([]byte, error)

func (*JsonCodec) Name

func (*JsonCodec) Name() string

func (*JsonCodec) Unmarshal

func (*JsonCodec) Unmarshal(data []byte, v interface{}) error

type OccClient

type OccClient interface {
	EventStream(ctx context.Context, in *pb.EventStreamRequest, opts ...grpc.CallOption) (pb.Occ_EventStreamClient, error)
	StateStream(ctx context.Context, in *pb.StateStreamRequest, opts ...grpc.CallOption) (pb.Occ_StateStreamClient, error)
	GetState(ctx context.Context, in *pb.GetStateRequest, opts ...grpc.CallOption) (*pb.GetStateReply, error)
	Transition(ctx context.Context, in *pb.TransitionRequest, opts ...grpc.CallOption) (*pb.TransitionReply, error)
}

Equivalent to the pb.OccClient interface so we can use protobuf-generated code

func NewOccClient

func NewOccClient(cc *grpc.ClientConn) OccClient