v1beta1

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 30, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var E2TClientFactory = func(cc *grpc.ClientConn) E2TServiceClient {
	return NewE2TServiceClient(cc)
}

E2TClientFactory : Default E2TClient creation.

Functions

func RegisterE2TServiceServer 

func RegisterE2TServiceServer(s *grpc.Server, srv E2TServiceServer)

Types

type AppID 

type AppID string

AppID is an application identifier

type ControlRequest 

type ControlRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ControlRequest

func (*ControlRequest) Descriptor 

func (*ControlRequest) Descriptor() ([]byte, []int)

func (*ControlRequest) ProtoMessage 

func (*ControlRequest) ProtoMessage()

func (*ControlRequest) Reset 

func (m *ControlRequest) Reset()

func (*ControlRequest) String 

func (m *ControlRequest) String() string

func (*ControlRequest) XXX_DiscardUnknown 

func (m *ControlRequest) XXX_DiscardUnknown()

func (*ControlRequest) XXX_Marshal 

func (m *ControlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlRequest) XXX_Merge 

func (m *ControlRequest) XXX_Merge(src proto.Message)

func (*ControlRequest) XXX_Size 

func (m *ControlRequest) XXX_Size() int

func (*ControlRequest) XXX_Unmarshal 

func (m *ControlRequest) XXX_Unmarshal(b []byte) error

type ControlResponse 

type ControlResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ControlResponse

func (*ControlResponse) Descriptor 

func (*ControlResponse) Descriptor() ([]byte, []int)

func (*ControlResponse) ProtoMessage 

func (*ControlResponse) ProtoMessage()

func (*ControlResponse) Reset 

func (m *ControlResponse) Reset()

func (*ControlResponse) String 

func (m *ControlResponse) String() string

func (*ControlResponse) XXX_DiscardUnknown 

func (m *ControlResponse) XXX_DiscardUnknown()

func (*ControlResponse) XXX_Marshal 

func (m *ControlResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlResponse) XXX_Merge 

func (m *ControlResponse) XXX_Merge(src proto.Message)

func (*ControlResponse) XXX_Size 

func (m *ControlResponse) XXX_Size() int

func (*ControlResponse) XXX_Unmarshal 

func (m *ControlResponse) XXX_Unmarshal(b []byte) error

type E2TServiceClient 

type E2TServiceClient interface {
	// Stream opens an indications stream
	Stream(ctx context.Context, opts ...grpc.CallOption) (E2TService_StreamClient, error)
}

E2TServiceClient is the client API for E2TService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func CreateE2TServiceClient 

func CreateE2TServiceClient(cc *grpc.ClientConn) E2TServiceClient

CreateE2ServiceClient creates and returns a new config admin client

func NewE2TServiceClient 

func NewE2TServiceClient(cc *grpc.ClientConn) E2TServiceClient

type E2TServiceServer 

type E2TServiceServer interface {
	// Stream opens an indications stream
	Stream(E2TService_StreamServer) error
}

E2TServiceServer is the server API for E2TService service.

type E2TService_StreamClient 

type E2TService_StreamClient interface {
	Send(*StreamRequest) error
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type E2TService_StreamServer 

type E2TService_StreamServer interface {
	Send(*StreamResponse) error
	Recv() (*StreamRequest, error)
	grpc.ServerStream
}

type Indication 

type Indication struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Indication an indication message

func (*Indication) Descriptor 

func (*Indication) Descriptor() ([]byte, []int)

func (*Indication) ProtoMessage 

func (*Indication) ProtoMessage()

func (*Indication) Reset 

func (m *Indication) Reset()

func (*Indication) String 

func (m *Indication) String() string

func (*Indication) XXX_DiscardUnknown 

func (m *Indication) XXX_DiscardUnknown()

func (*Indication) XXX_Marshal 

func (m *Indication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Indication) XXX_Merge 

func (m *Indication) XXX_Merge(src proto.Message)

func (*Indication) XXX_Size 

func (m *Indication) XXX_Size() int

func (*Indication) XXX_Unmarshal 

func (m *Indication) XXX_Unmarshal(b []byte) error

type InstanceID 

type InstanceID string

InstanceID is an application instance identifier

type StreamRequest 

type StreamRequest struct {
	AppID                AppID                `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	InstanceID           InstanceID           `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3,casttype=InstanceID" json:"instance_id,omitempty"`
	SubscriptionID       SubscriptionID       `` /* 127-byte string literal not displayed */
	Encoding             v1beta1.EncodingType `protobuf:"varint,4,opt,name=encoding,proto3,enum=ricapi.e2.headers.v1beta1.EncodingType" json:"encoding,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StreamRequest) Descriptor 

func (*StreamRequest) Descriptor() ([]byte, []int)

func (*StreamRequest) GetAppID 

func (m *StreamRequest) GetAppID() AppID

func (*StreamRequest) GetEncoding 

func (m *StreamRequest) GetEncoding() v1beta1.EncodingType

func (*StreamRequest) GetInstanceID 

func (m *StreamRequest) GetInstanceID() InstanceID

func (*StreamRequest) GetSubscriptionID 

func (m *StreamRequest) GetSubscriptionID() SubscriptionID

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) Reset 

func (m *StreamRequest) Reset()

func (*StreamRequest) String 

func (m *StreamRequest) String() string

func (*StreamRequest) XXX_DiscardUnknown 

func (m *StreamRequest) XXX_DiscardUnknown()

func (*StreamRequest) XXX_Marshal 

func (m *StreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamRequest) XXX_Merge 

func (m *StreamRequest) XXX_Merge(src proto.Message)

func (*StreamRequest) XXX_Size 

func (m *StreamRequest) XXX_Size() int

func (*StreamRequest) XXX_Unmarshal 

func (m *StreamRequest) XXX_Unmarshal(b []byte) error

type StreamResponse 

type StreamResponse struct {
	IndicationHeader     *v1beta1.ResponseHeader `protobuf:"bytes,1,opt,name=indication_header,json=indicationHeader,proto3" json:"indication_header,omitempty"`
	IndicationMessage    []byte                  `protobuf:"bytes,2,opt,name=indication_message,json=indicationMessage,proto3" json:"indication_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*StreamResponse) Descriptor 

func (*StreamResponse) Descriptor() ([]byte, []int)

func (*StreamResponse) GetIndicationHeader 

func (m *StreamResponse) GetIndicationHeader() *v1beta1.ResponseHeader

func (*StreamResponse) GetIndicationMessage 

func (m *StreamResponse) GetIndicationMessage() []byte

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset 

func (m *StreamResponse) Reset()

func (*StreamResponse) String 

func (m *StreamResponse) String() string

func (*StreamResponse) XXX_DiscardUnknown 

func (m *StreamResponse) XXX_DiscardUnknown()

func (*StreamResponse) XXX_Marshal 

func (m *StreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamResponse) XXX_Merge 

func (m *StreamResponse) XXX_Merge(src proto.Message)

func (*StreamResponse) XXX_Size 

func (m *StreamResponse) XXX_Size() int

func (*StreamResponse) XXX_Unmarshal 

func (m *StreamResponse) XXX_Unmarshal(b []byte) error

type SubscriptionID 

type SubscriptionID string

SubscriptionID is a subscription identifier

type UnimplementedE2TServiceServer 

type UnimplementedE2TServiceServer struct {
}

UnimplementedE2TServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2TServiceServer) Stream 

func (*UnimplementedE2TServiceServer) Stream(srv E2TService_StreamServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.