subscription

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: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSubscription        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSubscription          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSubscription = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Encoding_name = map[int32]string{
	0: "ENCODING_ASN1",
	1: "ENCODING_PROTO",
}
View Source 
var Encoding_value = map[string]int32{
	"ENCODING_ASN1":  0,
	"ENCODING_PROTO": 1,
}
View Source 
var EventType_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	2: "UPDATED",
	3: "REMOVED",
}
View Source 
var EventType_value = map[string]int32{
	"NONE":    0,
	"ADDED":   1,
	"UPDATED": 2,
	"REMOVED": 3,
}
View Source 
var Status_name = map[int32]string{
	0: "ACTIVE",
	1: "PENDING_DELETE",
}
View Source 
var Status_value = map[string]int32{
	"ACTIVE":         0,
	"PENDING_DELETE": 1,
}

Functions

func RegisterE2SubscriptionServiceServer 

func RegisterE2SubscriptionServiceServer(s *grpc.Server, srv E2SubscriptionServiceServer)

Types

type AddSubscriptionRequest 

type AddSubscriptionRequest struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
}

AddSubscriptionRequest a subscription request

func (*AddSubscriptionRequest) Descriptor 

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

func (*AddSubscriptionRequest) GetSubscription 

func (m *AddSubscriptionRequest) GetSubscription() *Subscription

func (*AddSubscriptionRequest) Marshal 

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

func (*AddSubscriptionRequest) MarshalTo 

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

func (*AddSubscriptionRequest) MarshalToSizedBuffer 

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

func (*AddSubscriptionRequest) ProtoMessage 

func (*AddSubscriptionRequest) ProtoMessage()

func (*AddSubscriptionRequest) Reset 

func (m *AddSubscriptionRequest) Reset()

func (*AddSubscriptionRequest) Size 

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

func (*AddSubscriptionRequest) String 

func (m *AddSubscriptionRequest) String() string

func (*AddSubscriptionRequest) Unmarshal 

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

func (*AddSubscriptionRequest) XXX_DiscardUnknown 

func (m *AddSubscriptionRequest) XXX_DiscardUnknown()

func (*AddSubscriptionRequest) XXX_Marshal 

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

func (*AddSubscriptionRequest) XXX_Merge 

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

func (*AddSubscriptionRequest) XXX_Size 

func (m *AddSubscriptionRequest) XXX_Size() int

func (*AddSubscriptionRequest) XXX_Unmarshal 

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

type AddSubscriptionResponse 

type AddSubscriptionResponse struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
}

AddSubscriptionResponse a subscription response

func (*AddSubscriptionResponse) Descriptor 

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

func (*AddSubscriptionResponse) GetSubscription 

func (m *AddSubscriptionResponse) GetSubscription() *Subscription

func (*AddSubscriptionResponse) Marshal 

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

func (*AddSubscriptionResponse) MarshalTo 

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

func (*AddSubscriptionResponse) MarshalToSizedBuffer 

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

func (*AddSubscriptionResponse) ProtoMessage 

func (*AddSubscriptionResponse) ProtoMessage()

func (*AddSubscriptionResponse) Reset 

func (m *AddSubscriptionResponse) Reset()

func (*AddSubscriptionResponse) Size 

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

func (*AddSubscriptionResponse) String 

func (m *AddSubscriptionResponse) String() string

func (*AddSubscriptionResponse) Unmarshal 

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

func (*AddSubscriptionResponse) XXX_DiscardUnknown 

func (m *AddSubscriptionResponse) XXX_DiscardUnknown()

func (*AddSubscriptionResponse) XXX_Marshal 

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

func (*AddSubscriptionResponse) XXX_Merge 

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

func (*AddSubscriptionResponse) XXX_Size 

func (m *AddSubscriptionResponse) XXX_Size() int

func (*AddSubscriptionResponse) XXX_Unmarshal 

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

type AppID 

type AppID string

AppID is an application identifier

type E2NodeID 

type E2NodeID string

E2NodeID is an E2 node identifier

type E2SubscriptionServiceClient 

type E2SubscriptionServiceClient interface {
	// AddSubscription establishes E2 subscriptions on E2 Node.
	AddSubscription(ctx context.Context, in *AddSubscriptionRequest, opts ...grpc.CallOption) (*AddSubscriptionResponse, error)
	// RemoveSubscription removes E2 subscriptions on E2 Node.
	RemoveSubscription(ctx context.Context, in *RemoveSubscriptionRequest, opts ...grpc.CallOption) (*RemoveSubscriptionResponse, error)
	// GetSubscription retrieves information about a specific subscription in the list of existing subscriptions
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*GetSubscriptionResponse, error)
	// ListSubscriptions returns the list of current existing subscriptions
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	// WatchSubscriptions returns a stream of subscription changes
	WatchSubscriptions(ctx context.Context, in *WatchSubscriptionsRequest, opts ...grpc.CallOption) (E2SubscriptionService_WatchSubscriptionsClient, error)
}

E2SubscriptionServiceClient is the client API for E2SubscriptionService service.

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

func NewE2SubscriptionServiceClient 

func NewE2SubscriptionServiceClient(cc *grpc.ClientConn) E2SubscriptionServiceClient

type E2SubscriptionServiceServer 

type E2SubscriptionServiceServer interface {
	// AddSubscription establishes E2 subscriptions on E2 Node.
	AddSubscription(context.Context, *AddSubscriptionRequest) (*AddSubscriptionResponse, error)
	// RemoveSubscription removes E2 subscriptions on E2 Node.
	RemoveSubscription(context.Context, *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)
	// GetSubscription retrieves information about a specific subscription in the list of existing subscriptions
	GetSubscription(context.Context, *GetSubscriptionRequest) (*GetSubscriptionResponse, error)
	// ListSubscriptions returns the list of current existing subscriptions
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	// WatchSubscriptions returns a stream of subscription changes
	WatchSubscriptions(*WatchSubscriptionsRequest, E2SubscriptionService_WatchSubscriptionsServer) error
}

E2SubscriptionServiceServer is the server API for E2SubscriptionService service.

type E2SubscriptionService_WatchSubscriptionsClient 

type E2SubscriptionService_WatchSubscriptionsClient interface {
	Recv() (*WatchSubscriptionsResponse, error)
	grpc.ClientStream
}

type E2SubscriptionService_WatchSubscriptionsServer 

type E2SubscriptionService_WatchSubscriptionsServer interface {
	Send(*WatchSubscriptionsResponse) error
	grpc.ServerStream
}

type Encoding 

type Encoding int32

Encoding indicates a payload encoding 

const (
	Encoding_ENCODING_ASN1  Encoding = 0
	Encoding_ENCODING_PROTO Encoding = 1
)

func (Encoding) EnumDescriptor 

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

func (Encoding) String 

func (x Encoding) String() string

type Event 

type Event struct {
	Type         EventType    `protobuf:"varint,1,opt,name=type,proto3,enum=onos.e2sub.subscription.EventType" json:"type,omitempty"`
	Subscription Subscription `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription"`
}

Event is a subscription event

func (*Event) Descriptor 

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

func (*Event) GetSubscription 

func (m *Event) GetSubscription() Subscription

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventType 

type EventType int32

EventType is a subscription event type 

const (
	EventType_NONE    EventType = 0
	EventType_ADDED   EventType = 1
	EventType_UPDATED EventType = 2
	EventType_REMOVED EventType = 3
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type GetSubscriptionRequest 

type GetSubscriptionRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

func (*GetSubscriptionRequest) Descriptor 

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

func (*GetSubscriptionRequest) GetID 

func (m *GetSubscriptionRequest) GetID() ID

func (*GetSubscriptionRequest) Marshal 

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

func (*GetSubscriptionRequest) MarshalTo 

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

func (*GetSubscriptionRequest) MarshalToSizedBuffer 

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

func (*GetSubscriptionRequest) ProtoMessage 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) Reset 

func (m *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) Size 

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

func (*GetSubscriptionRequest) String 

func (m *GetSubscriptionRequest) String() string

func (*GetSubscriptionRequest) Unmarshal 

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

func (*GetSubscriptionRequest) XXX_DiscardUnknown 

func (m *GetSubscriptionRequest) XXX_DiscardUnknown()

func (*GetSubscriptionRequest) XXX_Marshal 

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

func (*GetSubscriptionRequest) XXX_Merge 

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

func (*GetSubscriptionRequest) XXX_Size 

func (m *GetSubscriptionRequest) XXX_Size() int

func (*GetSubscriptionRequest) XXX_Unmarshal 

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

type GetSubscriptionResponse 

type GetSubscriptionResponse struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
}

func (*GetSubscriptionResponse) Descriptor 

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

func (*GetSubscriptionResponse) GetSubscription 

func (m *GetSubscriptionResponse) GetSubscription() *Subscription

func (*GetSubscriptionResponse) Marshal 

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

func (*GetSubscriptionResponse) MarshalTo 

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

func (*GetSubscriptionResponse) MarshalToSizedBuffer 

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

func (*GetSubscriptionResponse) ProtoMessage 

func (*GetSubscriptionResponse) ProtoMessage()

func (*GetSubscriptionResponse) Reset 

func (m *GetSubscriptionResponse) Reset()

func (*GetSubscriptionResponse) Size 

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

func (*GetSubscriptionResponse) String 

func (m *GetSubscriptionResponse) String() string

func (*GetSubscriptionResponse) Unmarshal 

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

func (*GetSubscriptionResponse) XXX_DiscardUnknown 

func (m *GetSubscriptionResponse) XXX_DiscardUnknown()

func (*GetSubscriptionResponse) XXX_Marshal 

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

func (*GetSubscriptionResponse) XXX_Merge 

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

func (*GetSubscriptionResponse) XXX_Size 

func (m *GetSubscriptionResponse) XXX_Size() int

func (*GetSubscriptionResponse) XXX_Unmarshal 

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

type ID 

type ID string

ID is a device ID

type Lifecycle 

type Lifecycle struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=onos.e2sub.subscription.Status" json:"status,omitempty"`
}

Lifecycle is the subscription lifecycle

func (*Lifecycle) Descriptor 

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

func (*Lifecycle) GetStatus 

func (m *Lifecycle) GetStatus() Status

func (*Lifecycle) Marshal 

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

func (*Lifecycle) MarshalTo 

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

func (*Lifecycle) MarshalToSizedBuffer 

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

func (*Lifecycle) ProtoMessage 

func (*Lifecycle) ProtoMessage()

func (*Lifecycle) Reset 

func (m *Lifecycle) Reset()

func (*Lifecycle) Size 

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

func (*Lifecycle) String 

func (m *Lifecycle) String() string

func (*Lifecycle) Unmarshal 

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

func (*Lifecycle) XXX_DiscardUnknown 

func (m *Lifecycle) XXX_DiscardUnknown()

func (*Lifecycle) XXX_Marshal 

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

func (*Lifecycle) XXX_Merge 

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

func (*Lifecycle) XXX_Size 

func (m *Lifecycle) XXX_Size() int

func (*Lifecycle) XXX_Unmarshal 

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

type ListSubscriptionsRequest 

type ListSubscriptionsRequest struct {
}

func (*ListSubscriptionsRequest) Descriptor 

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

func (*ListSubscriptionsRequest) Marshal 

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

func (*ListSubscriptionsRequest) MarshalTo 

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

func (*ListSubscriptionsRequest) MarshalToSizedBuffer 

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

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) Reset 

func (m *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) Size 

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

func (*ListSubscriptionsRequest) String 

func (m *ListSubscriptionsRequest) String() string

func (*ListSubscriptionsRequest) Unmarshal 

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

func (*ListSubscriptionsRequest) XXX_DiscardUnknown 

func (m *ListSubscriptionsRequest) XXX_DiscardUnknown()

func (*ListSubscriptionsRequest) XXX_Marshal 

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

func (*ListSubscriptionsRequest) XXX_Merge 

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

func (*ListSubscriptionsRequest) XXX_Size 

func (m *ListSubscriptionsRequest) XXX_Size() int

func (*ListSubscriptionsRequest) XXX_Unmarshal 

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

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {
	Subscriptions []Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions"`
}

func (*ListSubscriptionsResponse) Descriptor 

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

func (*ListSubscriptionsResponse) GetSubscriptions 

func (m *ListSubscriptionsResponse) GetSubscriptions() []Subscription

func (*ListSubscriptionsResponse) Marshal 

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

func (*ListSubscriptionsResponse) MarshalTo 

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

func (*ListSubscriptionsResponse) MarshalToSizedBuffer 

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

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) Reset 

func (m *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) Size 

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

func (*ListSubscriptionsResponse) String 

func (m *ListSubscriptionsResponse) String() string

func (*ListSubscriptionsResponse) Unmarshal 

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

func (*ListSubscriptionsResponse) XXX_DiscardUnknown 

func (m *ListSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListSubscriptionsResponse) XXX_Marshal 

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

func (*ListSubscriptionsResponse) XXX_Merge 

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

func (*ListSubscriptionsResponse) XXX_Size 

func (m *ListSubscriptionsResponse) XXX_Size() int

func (*ListSubscriptionsResponse) XXX_Unmarshal 

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

type Payload 

type Payload struct {
	Encoding Encoding `protobuf:"varint,1,opt,name=encoding,proto3,enum=onos.e2sub.subscription.Encoding" json:"encoding,omitempty"`
	Bytes    []byte   `protobuf:"bytes,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
}

Payload is a subscription payload

func (*Payload) Descriptor 

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

func (*Payload) GetBytes 

func (m *Payload) GetBytes() []byte

func (*Payload) GetEncoding 

func (m *Payload) GetEncoding() Encoding

func (*Payload) Marshal 

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

func (*Payload) MarshalTo 

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

func (*Payload) MarshalToSizedBuffer 

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

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size 

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

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal 

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

func (*Payload) XXX_DiscardUnknown 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal 

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

func (*Payload) XXX_Merge 

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

func (*Payload) XXX_Size 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal 

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

type RemoveSubscriptionRequest 

type RemoveSubscriptionRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

RemoveSubscriptionRequest a subscription delete request

func (*RemoveSubscriptionRequest) Descriptor 

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

func (*RemoveSubscriptionRequest) GetID 

func (m *RemoveSubscriptionRequest) GetID() ID

func (*RemoveSubscriptionRequest) Marshal 

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

func (*RemoveSubscriptionRequest) MarshalTo 

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

func (*RemoveSubscriptionRequest) MarshalToSizedBuffer 

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

func (*RemoveSubscriptionRequest) ProtoMessage 

func (*RemoveSubscriptionRequest) ProtoMessage()

func (*RemoveSubscriptionRequest) Reset 

func (m *RemoveSubscriptionRequest) Reset()

func (*RemoveSubscriptionRequest) Size 

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

func (*RemoveSubscriptionRequest) String 

func (m *RemoveSubscriptionRequest) String() string

func (*RemoveSubscriptionRequest) Unmarshal 

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

func (*RemoveSubscriptionRequest) XXX_DiscardUnknown 

func (m *RemoveSubscriptionRequest) XXX_DiscardUnknown()

func (*RemoveSubscriptionRequest) XXX_Marshal 

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

func (*RemoveSubscriptionRequest) XXX_Merge 

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

func (*RemoveSubscriptionRequest) XXX_Size 

func (m *RemoveSubscriptionRequest) XXX_Size() int

func (*RemoveSubscriptionRequest) XXX_Unmarshal 

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

type RemoveSubscriptionResponse 

type RemoveSubscriptionResponse struct {
}

RemoveSubscriptionResponse a subscription delete response

func (*RemoveSubscriptionResponse) Descriptor 

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

func (*RemoveSubscriptionResponse) Marshal 

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

func (*RemoveSubscriptionResponse) MarshalTo 

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

func (*RemoveSubscriptionResponse) MarshalToSizedBuffer 

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

func (*RemoveSubscriptionResponse) ProtoMessage 

func (*RemoveSubscriptionResponse) ProtoMessage()

func (*RemoveSubscriptionResponse) Reset 

func (m *RemoveSubscriptionResponse) Reset()

func (*RemoveSubscriptionResponse) Size 

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

func (*RemoveSubscriptionResponse) String 

func (m *RemoveSubscriptionResponse) String() string

func (*RemoveSubscriptionResponse) Unmarshal 

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

func (*RemoveSubscriptionResponse) XXX_DiscardUnknown 

func (m *RemoveSubscriptionResponse) XXX_DiscardUnknown()

func (*RemoveSubscriptionResponse) XXX_Marshal 

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

func (*RemoveSubscriptionResponse) XXX_Merge 

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

func (*RemoveSubscriptionResponse) XXX_Size 

func (m *RemoveSubscriptionResponse) XXX_Size() int

func (*RemoveSubscriptionResponse) XXX_Unmarshal 

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

type Revision 

type Revision uint64

Revision is a subscription revision

type ServiceModel 

type ServiceModel struct {
	ID ServiceModelID `protobuf:"bytes,4,opt,name=id,proto3,casttype=ServiceModelID" json:"id,omitempty"`
}

ServiceModel is a service model definition

func (*ServiceModel) Descriptor 

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

func (*ServiceModel) GetID 

func (m *ServiceModel) GetID() ServiceModelID

func (*ServiceModel) Marshal 

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

func (*ServiceModel) MarshalTo 

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

func (*ServiceModel) MarshalToSizedBuffer 

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

func (*ServiceModel) ProtoMessage 

func (*ServiceModel) ProtoMessage()

func (*ServiceModel) Reset 

func (m *ServiceModel) Reset()

func (*ServiceModel) Size 

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

func (*ServiceModel) String 

func (m *ServiceModel) String() string

func (*ServiceModel) Unmarshal 

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

func (*ServiceModel) XXX_DiscardUnknown 

func (m *ServiceModel) XXX_DiscardUnknown()

func (*ServiceModel) XXX_Marshal 

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

func (*ServiceModel) XXX_Merge 

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

func (*ServiceModel) XXX_Size 

func (m *ServiceModel) XXX_Size() int

func (*ServiceModel) XXX_Unmarshal 

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

type ServiceModelID 

type ServiceModelID string

ServiceModelID is a service model identifier

type Status 

type Status int32

Status is a subscription status 

const (
	Status_ACTIVE         Status = 0
	Status_PENDING_DELETE Status = 1
)

func (Status) EnumDescriptor 

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

func (Status) String 

func (x Status) String() string

type Subscription 

type Subscription struct {
	ID           ID            `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
	Revision     Revision      `protobuf:"varint,2,opt,name=revision,proto3,casttype=Revision" json:"revision,omitempty"`
	AppID        AppID         `protobuf:"bytes,3,opt,name=app_id,json=appId,proto3,casttype=AppID" json:"app_id,omitempty"`
	E2NodeID     E2NodeID      `protobuf:"bytes,4,opt,name=e2_node_id,json=e2NodeId,proto3,casttype=E2NodeID" json:"e2_node_id,omitempty"`
	ServiceModel *ServiceModel `protobuf:"bytes,5,opt,name=service_model,json=serviceModel,proto3" json:"service_model,omitempty"`
	Payload      *Payload      `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	Lifecycle    Lifecycle     `protobuf:"bytes,7,opt,name=lifecycle,proto3" json:"lifecycle"`
}

Subscription is a subscription state

func (*Subscription) Descriptor 

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

func (*Subscription) GetAppID 

func (m *Subscription) GetAppID() AppID

func (*Subscription) GetE2NodeID 

func (m *Subscription) GetE2NodeID() E2NodeID

func (*Subscription) GetID 

func (m *Subscription) GetID() ID

func (*Subscription) GetLifecycle 

func (m *Subscription) GetLifecycle() Lifecycle

func (*Subscription) GetPayload 

func (m *Subscription) GetPayload() *Payload

func (*Subscription) GetRevision 

func (m *Subscription) GetRevision() Revision

func (*Subscription) GetServiceModel 

func (m *Subscription) GetServiceModel() *ServiceModel

func (*Subscription) Marshal 

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

func (*Subscription) MarshalTo 

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

func (*Subscription) MarshalToSizedBuffer 

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

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) Size 

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

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) Unmarshal 

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

func (*Subscription) XXX_DiscardUnknown 

func (m *Subscription) XXX_DiscardUnknown()

func (*Subscription) XXX_Marshal 

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

func (*Subscription) XXX_Merge 

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

func (*Subscription) XXX_Size 

func (m *Subscription) XXX_Size() int

func (*Subscription) XXX_Unmarshal 

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

type UnimplementedE2SubscriptionServiceServer 

type UnimplementedE2SubscriptionServiceServer struct {
}

UnimplementedE2SubscriptionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedE2SubscriptionServiceServer) AddSubscription 

func (*UnimplementedE2SubscriptionServiceServer) AddSubscription(ctx context.Context, req *AddSubscriptionRequest) (*AddSubscriptionResponse, error)

func (*UnimplementedE2SubscriptionServiceServer) GetSubscription 

func (*UnimplementedE2SubscriptionServiceServer) GetSubscription(ctx context.Context, req *GetSubscriptionRequest) (*GetSubscriptionResponse, error)

func (*UnimplementedE2SubscriptionServiceServer) ListSubscriptions 

func (*UnimplementedE2SubscriptionServiceServer) ListSubscriptions(ctx context.Context, req *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

func (*UnimplementedE2SubscriptionServiceServer) RemoveSubscription 

func (*UnimplementedE2SubscriptionServiceServer) RemoveSubscription(ctx context.Context, req *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)

func (*UnimplementedE2SubscriptionServiceServer) WatchSubscriptions 

func (*UnimplementedE2SubscriptionServiceServer) WatchSubscriptions(req *WatchSubscriptionsRequest, srv E2SubscriptionService_WatchSubscriptionsServer) error

type WatchSubscriptionsRequest 

type WatchSubscriptionsRequest struct {
	Noreplay bool `protobuf:"varint,1,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
}

func (*WatchSubscriptionsRequest) Descriptor 

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

func (*WatchSubscriptionsRequest) GetNoreplay 

func (m *WatchSubscriptionsRequest) GetNoreplay() bool

func (*WatchSubscriptionsRequest) Marshal 

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

func (*WatchSubscriptionsRequest) MarshalTo 

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

func (*WatchSubscriptionsRequest) MarshalToSizedBuffer 

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

func (*WatchSubscriptionsRequest) ProtoMessage 

func (*WatchSubscriptionsRequest) ProtoMessage()

func (*WatchSubscriptionsRequest) Reset 

func (m *WatchSubscriptionsRequest) Reset()

func (*WatchSubscriptionsRequest) Size 

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

func (*WatchSubscriptionsRequest) String 

func (m *WatchSubscriptionsRequest) String() string

func (*WatchSubscriptionsRequest) Unmarshal 

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

func (*WatchSubscriptionsRequest) XXX_DiscardUnknown 

func (m *WatchSubscriptionsRequest) XXX_DiscardUnknown()

func (*WatchSubscriptionsRequest) XXX_Marshal 

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

func (*WatchSubscriptionsRequest) XXX_Merge 

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

func (*WatchSubscriptionsRequest) XXX_Size 

func (m *WatchSubscriptionsRequest) XXX_Size() int

func (*WatchSubscriptionsRequest) XXX_Unmarshal 

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

type WatchSubscriptionsResponse 

type WatchSubscriptionsResponse struct {
	Event Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
}

func (*WatchSubscriptionsResponse) Descriptor 

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

func (*WatchSubscriptionsResponse) GetEvent 

func (m *WatchSubscriptionsResponse) GetEvent() Event

func (*WatchSubscriptionsResponse) Marshal 

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

func (*WatchSubscriptionsResponse) MarshalTo 

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

func (*WatchSubscriptionsResponse) MarshalToSizedBuffer 

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

func (*WatchSubscriptionsResponse) ProtoMessage 

func (*WatchSubscriptionsResponse) ProtoMessage()

func (*WatchSubscriptionsResponse) Reset 

func (m *WatchSubscriptionsResponse) Reset()

func (*WatchSubscriptionsResponse) Size 

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

func (*WatchSubscriptionsResponse) String 

func (m *WatchSubscriptionsResponse) String() string

func (*WatchSubscriptionsResponse) Unmarshal 

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

func (*WatchSubscriptionsResponse) XXX_DiscardUnknown 

func (m *WatchSubscriptionsResponse) XXX_DiscardUnknown()

func (*WatchSubscriptionsResponse) XXX_Marshal 

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

func (*WatchSubscriptionsResponse) XXX_Merge 

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

func (*WatchSubscriptionsResponse) XXX_Size 

func (m *WatchSubscriptionsResponse) XXX_Size() int

func (*WatchSubscriptionsResponse) XXX_Unmarshal 

func (m *WatchSubscriptionsResponse) XXX_Unmarshal(b []byte) 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.