Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

      Directories

      Path Synopsis