e2

package
v0.6.5 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2020 License: Apache-2.0 Imports: 10 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthE2        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowE2          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupE2 = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EncodingType_name = map[int32]string{
	0: "PROTO",
	1: "ASN1_PER",
	2: "ASN1_XER",
}
View Source 
var EncodingType_value = map[string]int32{
	"PROTO":    0,
	"ASN1_PER": 1,
	"ASN1_XER": 2,
}
View Source 
var ResponseStatus_name = map[int32]string{
	0: "FAILED",
	1: "SUCCEEDED",
}
View Source 
var ResponseStatus_value = map[string]int32{
	"FAILED":    0,
	"SUCCEEDED": 1,
}

Functions

func RegisterE2TServiceServer 

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

Types

type AppID 

type AppID string

AppID is an application identifier

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 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 EncodingType 

type EncodingType int32

EncodingType determines encoding type for the response messages 

const (
	EncodingType_PROTO    EncodingType = 0
	EncodingType_ASN1_PER EncodingType = 1
	EncodingType_ASN1_XER EncodingType = 2
)

func (EncodingType) EnumDescriptor 

func (EncodingType) EnumDescriptor() ([]byte, []int)

func (EncodingType) String 

func (x EncodingType) String() string

type InstanceID 

type InstanceID string

InstanceID is an application instance identifier

type RequestHeader 

type RequestHeader struct {
	EncodingType     EncodingType      `` /* 128-byte string literal not displayed */
	ServiceModelInfo *ServiceModelInfo `protobuf:"bytes,2,opt,name=service_model_info,json=serviceModelInfo,proto3" json:"service_model_info,omitempty"`
}

RequestHeader a common request header for all requests including encoding type, client/xApp/session info, ordering info, etc

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetEncodingType 

func (m *RequestHeader) GetEncodingType() EncodingType

func (*RequestHeader) GetServiceModelInfo 

func (m *RequestHeader) GetServiceModelInfo() *ServiceModelInfo

func (*RequestHeader) Marshal 

func (m *RequestHeader) Marshal() (dAtA []byte, err error)

func (*RequestHeader) MarshalTo 

func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)

func (*RequestHeader) MarshalToSizedBuffer 

func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

func (m *RequestHeader) Size() (n int)

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

func (m *RequestHeader) Unmarshal(dAtA []byte) error

func (*RequestHeader) XXX_DiscardUnknown 

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal 

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

func (*RequestHeader) XXX_Merge 

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

func (*RequestHeader) XXX_Size 

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal 

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

type ResponseHeader 

type ResponseHeader struct {
	EncodingType     EncodingType      `` /* 128-byte string literal not displayed */
	ServiceModelInfo *ServiceModelInfo `protobuf:"bytes,2,opt,name=service_model_info,json=serviceModelInfo,proto3" json:"service_model_info,omitempty"`
	ResponseStatus   ResponseStatus    `` /* 136-byte string literal not displayed */
}

ResponseHeader a common response header for all responses including encoding type, client/xApp/session info, ordering info, etc

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetEncodingType 

func (m *ResponseHeader) GetEncodingType() EncodingType

func (*ResponseHeader) GetResponseStatus 

func (m *ResponseHeader) GetResponseStatus() ResponseStatus

func (*ResponseHeader) GetServiceModelInfo 

func (m *ResponseHeader) GetServiceModelInfo() *ServiceModelInfo

func (*ResponseHeader) Marshal 

func (m *ResponseHeader) Marshal() (dAtA []byte, err error)

func (*ResponseHeader) MarshalTo 

func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)

func (*ResponseHeader) MarshalToSizedBuffer 

func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

func (m *ResponseHeader) Size() (n int)

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

func (m *ResponseHeader) Unmarshal(dAtA []byte) error

func (*ResponseHeader) XXX_DiscardUnknown 

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal 

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

func (*ResponseHeader) XXX_Merge 

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

func (*ResponseHeader) XXX_Size 

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal 

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

type ResponseStatus 

type ResponseStatus int32

ResponseStatus 

const (
	ResponseStatus_FAILED    ResponseStatus = 0
	ResponseStatus_SUCCEEDED ResponseStatus = 1
)

func (ResponseStatus) EnumDescriptor 

func (ResponseStatus) EnumDescriptor() ([]byte, []int)

func (ResponseStatus) String 

func (x ResponseStatus) String() string

type ServiceModelInfo 

type ServiceModelInfo struct {
	ServiceModelId string `protobuf:"bytes,1,opt,name=service_model_id,json=serviceModelId,proto3" json:"service_model_id,omitempty"`
}

ServiceModelInfo E2 service model information

func (*ServiceModelInfo) Descriptor 

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

func (*ServiceModelInfo) GetServiceModelId 

func (m *ServiceModelInfo) GetServiceModelId() string

func (*ServiceModelInfo) Marshal 

func (m *ServiceModelInfo) Marshal() (dAtA []byte, err error)

func (*ServiceModelInfo) MarshalTo 

func (m *ServiceModelInfo) MarshalTo(dAtA []byte) (int, error)

func (*ServiceModelInfo) MarshalToSizedBuffer 

func (m *ServiceModelInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceModelInfo) ProtoMessage 

func (*ServiceModelInfo) ProtoMessage()

func (*ServiceModelInfo) Reset 

func (m *ServiceModelInfo) Reset()

func (*ServiceModelInfo) Size 

func (m *ServiceModelInfo) Size() (n int)

func (*ServiceModelInfo) String 

func (m *ServiceModelInfo) String() string

func (*ServiceModelInfo) Unmarshal 

func (m *ServiceModelInfo) Unmarshal(dAtA []byte) error

func (*ServiceModelInfo) XXX_DiscardUnknown 

func (m *ServiceModelInfo) XXX_DiscardUnknown()

func (*ServiceModelInfo) XXX_Marshal 

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

func (*ServiceModelInfo) XXX_Merge 

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

func (*ServiceModelInfo) XXX_Size 

func (m *ServiceModelInfo) XXX_Size() int

func (*ServiceModelInfo) XXX_Unmarshal 

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

type StreamRequest 

type StreamRequest struct {
	Header         *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AppID          AppID          `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	InstanceID     InstanceID     `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3,casttype=InstanceID" json:"instance_id,omitempty"`
	SubscriptionID SubscriptionID `` /* 127-byte string literal not displayed */
}

StreamRequest

func (*StreamRequest) Descriptor 

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

func (*StreamRequest) GetAppID 

func (m *StreamRequest) GetAppID() AppID

func (*StreamRequest) GetHeader 

func (m *StreamRequest) GetHeader() *RequestHeader

func (*StreamRequest) GetInstanceID 

func (m *StreamRequest) GetInstanceID() InstanceID

func (*StreamRequest) GetSubscriptionID 

func (m *StreamRequest) GetSubscriptionID() SubscriptionID

func (*StreamRequest) Marshal 

func (m *StreamRequest) Marshal() (dAtA []byte, err error)

func (*StreamRequest) MarshalTo 

func (m *StreamRequest) MarshalTo(dAtA []byte) (int, error)

func (*StreamRequest) MarshalToSizedBuffer 

func (m *StreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) Reset 

func (m *StreamRequest) Reset()

func (*StreamRequest) Size 

func (m *StreamRequest) Size() (n int)

func (*StreamRequest) String 

func (m *StreamRequest) String() string

func (*StreamRequest) Unmarshal 

func (m *StreamRequest) Unmarshal(dAtA []byte) error

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 {
	Header  *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte          `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

StreamResponse

func (*StreamResponse) Descriptor 

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

func (*StreamResponse) GetHeader 

func (m *StreamResponse) GetHeader() *ResponseHeader

func (*StreamResponse) GetPayload 

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

func (*StreamResponse) Marshal 

func (m *StreamResponse) Marshal() (dAtA []byte, err error)

func (*StreamResponse) MarshalTo 

func (m *StreamResponse) MarshalTo(dAtA []byte) (int, error)

func (*StreamResponse) MarshalToSizedBuffer 

func (m *StreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset 

func (m *StreamResponse) Reset()

func (*StreamResponse) Size 

func (m *StreamResponse) Size() (n int)

func (*StreamResponse) String 

func (m *StreamResponse) String() string

func (*StreamResponse) Unmarshal 

func (m *StreamResponse) Unmarshal(dAtA []byte) error

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.