events

package
v0.0.0-...-695150b Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEventsHandler 

func RegisterEventsHandler(s server.Server, hdlr EventsHandler, opts ...server.HandlerOption) error

Types

type DefaultEventSubRequest 

type DefaultEventSubRequest struct {
	SystemID             []string `protobuf:"bytes,1,rep,name=SystemID,proto3" json:"SystemID,omitempty"`
	EventTypes           []string `protobuf:"bytes,2,rep,name=EventTypes,proto3" json:"EventTypes,omitempty"`
	MessageIDs           []string `protobuf:"bytes,3,rep,name=MessageIDs,proto3" json:"MessageIDs,omitempty"`
	ResourceTypes        []string `protobuf:"bytes,4,rep,name=ResourceTypes,proto3" json:"ResourceTypes,omitempty"`
	Protocol             string   `protobuf:"bytes,5,opt,name=Protocol,proto3" json:"Protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DefaultEventSubRequest) Descriptor 

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

func (*DefaultEventSubRequest) GetEventTypes 

func (m *DefaultEventSubRequest) GetEventTypes() []string

func (*DefaultEventSubRequest) GetMessageIDs 

func (m *DefaultEventSubRequest) GetMessageIDs() []string

func (*DefaultEventSubRequest) GetProtocol 

func (m *DefaultEventSubRequest) GetProtocol() string

func (*DefaultEventSubRequest) GetResourceTypes 

func (m *DefaultEventSubRequest) GetResourceTypes() []string

func (*DefaultEventSubRequest) GetSystemID 

func (m *DefaultEventSubRequest) GetSystemID() []string

func (*DefaultEventSubRequest) ProtoMessage 

func (*DefaultEventSubRequest) ProtoMessage()

func (*DefaultEventSubRequest) Reset 

func (m *DefaultEventSubRequest) Reset()

func (*DefaultEventSubRequest) String 

func (m *DefaultEventSubRequest) String() string

func (*DefaultEventSubRequest) XXX_DiscardUnknown 

func (m *DefaultEventSubRequest) XXX_DiscardUnknown()

func (*DefaultEventSubRequest) XXX_Marshal 

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

func (*DefaultEventSubRequest) XXX_Merge 

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

func (*DefaultEventSubRequest) XXX_Size 

func (m *DefaultEventSubRequest) XXX_Size() int

func (*DefaultEventSubRequest) XXX_Unmarshal 

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

type DefaultEventSubResponse 

type DefaultEventSubResponse struct {
	TaskURL              string   `protobuf:"bytes,1,opt,name=TaskURL,proto3" json:"TaskURL,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DefaultEventSubResponse) Descriptor 

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

func (*DefaultEventSubResponse) GetTaskURL 

func (m *DefaultEventSubResponse) GetTaskURL() string

func (*DefaultEventSubResponse) ProtoMessage 

func (*DefaultEventSubResponse) ProtoMessage()

func (*DefaultEventSubResponse) Reset 

func (m *DefaultEventSubResponse) Reset()

func (*DefaultEventSubResponse) String 

func (m *DefaultEventSubResponse) String() string

func (*DefaultEventSubResponse) XXX_DiscardUnknown 

func (m *DefaultEventSubResponse) XXX_DiscardUnknown()

func (*DefaultEventSubResponse) XXX_Marshal 

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

func (*DefaultEventSubResponse) XXX_Merge 

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

func (*DefaultEventSubResponse) XXX_Size 

func (m *DefaultEventSubResponse) XXX_Size() int

func (*DefaultEventSubResponse) XXX_Unmarshal 

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

type EventRequest 

type EventRequest struct {
	SessionToken         string   `protobuf:"bytes,1,opt,name=SessionToken,proto3" json:"SessionToken,omitempty"`
	EventSubscriptionID  string   `protobuf:"bytes,2,opt,name=EventSubscriptionID,proto3" json:"EventSubscriptionID,omitempty"`
	UUID                 string   `protobuf:"bytes,3,opt,name=UUID,proto3" json:"UUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventRequest) Descriptor 

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

func (*EventRequest) GetEventSubscriptionID 

func (m *EventRequest) GetEventSubscriptionID() string

func (*EventRequest) GetSessionToken 

func (m *EventRequest) GetSessionToken() string

func (*EventRequest) GetUUID 

func (m *EventRequest) GetUUID() string

func (*EventRequest) ProtoMessage 

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset 

func (m *EventRequest) Reset()

func (*EventRequest) String 

func (m *EventRequest) String() string

func (*EventRequest) XXX_DiscardUnknown 

func (m *EventRequest) XXX_DiscardUnknown()

func (*EventRequest) XXX_Marshal 

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

func (*EventRequest) XXX_Merge 

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

func (*EventRequest) XXX_Size 

func (m *EventRequest) XXX_Size() int

func (*EventRequest) XXX_Unmarshal 

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

type EventSubRequest 

type EventSubRequest struct {
	SessionToken         string   `protobuf:"bytes,1,opt,name=SessionToken,proto3" json:"SessionToken,omitempty"`
	PostBody             []byte   `protobuf:"bytes,2,opt,name=PostBody,proto3" json:"PostBody,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventSubRequest) Descriptor 

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

func (*EventSubRequest) GetPostBody 

func (m *EventSubRequest) GetPostBody() []byte

func (*EventSubRequest) GetSessionToken 

func (m *EventSubRequest) GetSessionToken() string

func (*EventSubRequest) ProtoMessage 

func (*EventSubRequest) ProtoMessage()

func (*EventSubRequest) Reset 

func (m *EventSubRequest) Reset()

func (*EventSubRequest) String 

func (m *EventSubRequest) String() string

func (*EventSubRequest) XXX_DiscardUnknown 

func (m *EventSubRequest) XXX_DiscardUnknown()

func (*EventSubRequest) XXX_Marshal 

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

func (*EventSubRequest) XXX_Merge 

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

func (*EventSubRequest) XXX_Size 

func (m *EventSubRequest) XXX_Size() int

func (*EventSubRequest) XXX_Unmarshal 

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

type EventSubResponse 

type EventSubResponse struct {
	StatusCode           int32             `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	StatusMessage        string            `protobuf:"bytes,2,opt,name=statusMessage,proto3" json:"statusMessage,omitempty"`
	Location             string            `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	Body                 []byte            `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	Header               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EventSubResponse) Descriptor 

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

func (*EventSubResponse) GetBody 

func (m *EventSubResponse) GetBody() []byte

func (*EventSubResponse) GetHeader 

func (m *EventSubResponse) GetHeader() map[string]string

func (*EventSubResponse) GetLocation 

func (m *EventSubResponse) GetLocation() string

func (*EventSubResponse) GetStatusCode 

func (m *EventSubResponse) GetStatusCode() int32

func (*EventSubResponse) GetStatusMessage 

func (m *EventSubResponse) GetStatusMessage() string

func (*EventSubResponse) ProtoMessage 

func (*EventSubResponse) ProtoMessage()

func (*EventSubResponse) Reset 

func (m *EventSubResponse) Reset()

func (*EventSubResponse) String 

func (m *EventSubResponse) String() string

func (*EventSubResponse) XXX_DiscardUnknown 

func (m *EventSubResponse) XXX_DiscardUnknown()

func (*EventSubResponse) XXX_Marshal 

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

func (*EventSubResponse) XXX_Merge 

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

func (*EventSubResponse) XXX_Size 

func (m *EventSubResponse) XXX_Size() int

func (*EventSubResponse) XXX_Unmarshal 

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

type EventsHandler 

type EventsHandler interface {
	GetEventService(context.Context, *EventSubRequest, *EventSubResponse) error
	SubmitTestEvent(context.Context, *EventSubRequest, *EventSubResponse) error
	CreateEventSubscription(context.Context, *EventSubRequest, *EventSubResponse) error
	GetEventSubscription(context.Context, *EventRequest, *EventSubResponse) error
	DeleteEventSubscription(context.Context, *EventRequest, *EventSubResponse) error
	CreateDefaultEventSubscription(context.Context, *DefaultEventSubRequest, *DefaultEventSubResponse) error
	GetEventSubscriptionsCollection(context.Context, *EventRequest, *EventSubResponse) error
	SubsribeEMB(context.Context, *SubscribeEMBRequest, *SubscribeEMBResponse) error
}

type EventsService 

type EventsService interface {
	GetEventService(ctx context.Context, in *EventSubRequest, opts ...client.CallOption) (*EventSubResponse, error)
	SubmitTestEvent(ctx context.Context, in *EventSubRequest, opts ...client.CallOption) (*EventSubResponse, error)
	CreateEventSubscription(ctx context.Context, in *EventSubRequest, opts ...client.CallOption) (*EventSubResponse, error)
	GetEventSubscription(ctx context.Context, in *EventRequest, opts ...client.CallOption) (*EventSubResponse, error)
	DeleteEventSubscription(ctx context.Context, in *EventRequest, opts ...client.CallOption) (*EventSubResponse, error)
	CreateDefaultEventSubscription(ctx context.Context, in *DefaultEventSubRequest, opts ...client.CallOption) (*DefaultEventSubResponse, error)
	GetEventSubscriptionsCollection(ctx context.Context, in *EventRequest, opts ...client.CallOption) (*EventSubResponse, error)
	SubsribeEMB(ctx context.Context, in *SubscribeEMBRequest, opts ...client.CallOption) (*SubscribeEMBResponse, error)
}

func NewEventsService 

func NewEventsService(name string, c client.Client) EventsService

type SubscribeEMBRequest 

type SubscribeEMBRequest struct {
	PluginID             string   `protobuf:"bytes,1,opt,name=PluginID,proto3" json:"PluginID,omitempty"`
	EMBType              string   `protobuf:"bytes,2,opt,name=EMBType,proto3" json:"EMBType,omitempty"`
	EMBQueueName         []string `protobuf:"bytes,3,rep,name=EMBQueueName,proto3" json:"EMBQueueName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeEMBRequest) Descriptor 

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

func (*SubscribeEMBRequest) GetEMBQueueName 

func (m *SubscribeEMBRequest) GetEMBQueueName() []string

func (*SubscribeEMBRequest) GetEMBType 

func (m *SubscribeEMBRequest) GetEMBType() string

func (*SubscribeEMBRequest) GetPluginID 

func (m *SubscribeEMBRequest) GetPluginID() string

func (*SubscribeEMBRequest) ProtoMessage 

func (*SubscribeEMBRequest) ProtoMessage()

func (*SubscribeEMBRequest) Reset 

func (m *SubscribeEMBRequest) Reset()

func (*SubscribeEMBRequest) String 

func (m *SubscribeEMBRequest) String() string

func (*SubscribeEMBRequest) XXX_DiscardUnknown 

func (m *SubscribeEMBRequest) XXX_DiscardUnknown()

func (*SubscribeEMBRequest) XXX_Marshal 

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

func (*SubscribeEMBRequest) XXX_Merge 

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

func (*SubscribeEMBRequest) XXX_Size 

func (m *SubscribeEMBRequest) XXX_Size() int

func (*SubscribeEMBRequest) XXX_Unmarshal 

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

type SubscribeEMBResponse 

type SubscribeEMBResponse struct {
	Status               bool     `protobuf:"varint,1,opt,name=Status,proto3" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeEMBResponse) Descriptor 

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

func (*SubscribeEMBResponse) GetStatus 

func (m *SubscribeEMBResponse) GetStatus() bool

func (*SubscribeEMBResponse) ProtoMessage 

func (*SubscribeEMBResponse) ProtoMessage()

func (*SubscribeEMBResponse) Reset 

func (m *SubscribeEMBResponse) Reset()

func (*SubscribeEMBResponse) String 

func (m *SubscribeEMBResponse) String() string

func (*SubscribeEMBResponse) XXX_DiscardUnknown 

func (m *SubscribeEMBResponse) XXX_DiscardUnknown()

func (*SubscribeEMBResponse) XXX_Marshal 

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

func (*SubscribeEMBResponse) XXX_Merge 

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

func (*SubscribeEMBResponse) XXX_Size 

func (m *SubscribeEMBResponse) XXX_Size() int

func (*SubscribeEMBResponse) XXX_Unmarshal 

func (m *SubscribeEMBResponse) 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.