event

package
v0.0.0-...-0490640 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package event is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEventServiceServer 

func RegisterEventServiceServer(s *grpc.Server, srv EventServiceServer)

Types

type Actor 

type Actor struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty" toml:"ID,omitempty" mapstructure:"ID,omitempty"`
	ObjectType           string   `` /* 137-byte string literal not displayed */
	DisplayName          string   `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*Actor) Descriptor 

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

func (*Actor) GetDisplayName 

func (m *Actor) GetDisplayName() string

func (*Actor) GetID 

func (m *Actor) GetID() string

func (*Actor) GetObjectType 

func (m *Actor) GetObjectType() string

func (*Actor) ProtoMessage 

func (*Actor) ProtoMessage()

func (*Actor) Reset 

func (m *Actor) Reset()

func (*Actor) String 

func (m *Actor) String() string

func (*Actor) XXX_DiscardUnknown 

func (m *Actor) XXX_DiscardUnknown()

func (*Actor) XXX_Marshal 

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

func (*Actor) XXX_Merge 

func (dst *Actor) XXX_Merge(src proto.Message)

func (*Actor) XXX_Size 

func (m *Actor) XXX_Size() int

func (*Actor) XXX_Unmarshal 

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

type EventMsg 

type EventMsg struct {
	EventID              string               `protobuf:"bytes,1,opt,name=EventID,proto3" json:"EventID,omitempty" toml:"EventID,omitempty" mapstructure:"EventID,omitempty"`
	Type                 *EventType           `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty" toml:"Type,omitempty" mapstructure:"Type,omitempty"`
	Producer             *Producer            `` /* 129-byte string literal not displayed */
	Tags                 []string             `protobuf:"bytes,4,rep,name=Tags,proto3" json:"Tags,omitempty" toml:"Tags,omitempty" mapstructure:"Tags,omitempty"`
	Published            *timestamp.Timestamp `` /* 133-byte string literal not displayed */
	Actor                *Actor               `protobuf:"bytes,6,opt,name=Actor,proto3" json:"Actor,omitempty" toml:"Actor,omitempty" mapstructure:"Actor,omitempty"`
	Verb                 string               `protobuf:"bytes,7,opt,name=Verb,proto3" json:"Verb,omitempty" toml:"Verb,omitempty" mapstructure:"Verb,omitempty"`
	Object               *Object              `protobuf:"bytes,8,opt,name=Object,proto3" json:"Object,omitempty" toml:"Object,omitempty" mapstructure:"Object,omitempty"`
	Target               *Target              `protobuf:"bytes,9,opt,name=Target,proto3" json:"Target,omitempty" toml:"Target,omitempty" mapstructure:"Target,omitempty"`
	Data                 *_struct.Struct      `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty" toml:"data,omitempty" mapstructure:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte               `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32                `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*EventMsg) Descriptor 

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

func (*EventMsg) GetActor 

func (m *EventMsg) GetActor() *Actor

func (*EventMsg) GetData 

func (m *EventMsg) GetData() *_struct.Struct

func (*EventMsg) GetEventID 

func (m *EventMsg) GetEventID() string

func (*EventMsg) GetObject 

func (m *EventMsg) GetObject() *Object

func (*EventMsg) GetProducer 

func (m *EventMsg) GetProducer() *Producer

func (*EventMsg) GetPublished 

func (m *EventMsg) GetPublished() *timestamp.Timestamp

func (*EventMsg) GetTags 

func (m *EventMsg) GetTags() []string

func (*EventMsg) GetTarget 

func (m *EventMsg) GetTarget() *Target

func (*EventMsg) GetType 

func (m *EventMsg) GetType() *EventType

func (*EventMsg) GetVerb 

func (m *EventMsg) GetVerb() string

func (*EventMsg) ProtoMessage 

func (*EventMsg) ProtoMessage()

func (*EventMsg) Reset 

func (m *EventMsg) Reset()

func (*EventMsg) String 

func (m *EventMsg) String() string

func (*EventMsg) XXX_DiscardUnknown 

func (m *EventMsg) XXX_DiscardUnknown()

func (*EventMsg) XXX_Marshal 

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

func (*EventMsg) XXX_Merge 

func (dst *EventMsg) XXX_Merge(src proto.Message)

func (*EventMsg) XXX_Size 

func (m *EventMsg) XXX_Size() int

func (*EventMsg) XXX_Unmarshal 

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

type EventResponse 

type EventResponse struct {
	Success              bool     `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*EventResponse) Descriptor 

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

func (*EventResponse) GetSuccess 

func (m *EventResponse) GetSuccess() bool

func (*EventResponse) ProtoMessage 

func (*EventResponse) ProtoMessage()

func (*EventResponse) Reset 

func (m *EventResponse) Reset()

func (*EventResponse) String 

func (m *EventResponse) String() string

func (*EventResponse) XXX_DiscardUnknown 

func (m *EventResponse) XXX_DiscardUnknown()

func (*EventResponse) XXX_Marshal 

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

func (*EventResponse) XXX_Merge 

func (dst *EventResponse) XXX_Merge(src proto.Message)

func (*EventResponse) XXX_Size 

func (m *EventResponse) XXX_Size() int

func (*EventResponse) XXX_Unmarshal 

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

type EventServiceClient 

type EventServiceClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
}

EventServiceClient is the client API for EventService service.

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

func NewEventServiceClient 

func NewEventServiceClient(cc *grpc.ClientConn) EventServiceClient

type EventServiceServer 

type EventServiceServer interface {
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
}

EventServiceServer is the server API for EventService service.

type EventType 

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

func (*EventType) Descriptor 

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

func (*EventType) GetName 

func (m *EventType) GetName() string

func (*EventType) ProtoMessage 

func (*EventType) ProtoMessage()

func (*EventType) Reset 

func (m *EventType) Reset()

func (*EventType) String 

func (m *EventType) String() string

func (*EventType) XXX_DiscardUnknown 

func (m *EventType) XXX_DiscardUnknown()

func (*EventType) XXX_Marshal 

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

func (*EventType) XXX_Merge 

func (dst *EventType) XXX_Merge(src proto.Message)

func (*EventType) XXX_Size 

func (m *EventType) XXX_Size() int

func (*EventType) XXX_Unmarshal 

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

type MockEventServiceClient 

type MockEventServiceClient struct {
	// contains filtered or unexported fields
}

MockEventServiceClient is a mock of EventServiceClient interface

func NewMockEventServiceClient 

func NewMockEventServiceClient(ctrl *gomock.Controller) *MockEventServiceClient

NewMockEventServiceClient creates a new mock instance

func (*MockEventServiceClient) EXPECT 

func (m *MockEventServiceClient) EXPECT() *MockEventServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockEventServiceClient) Publish 

func (m *MockEventServiceClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

Publish mocks base method

func (*MockEventServiceClient) Start 

func (m *MockEventServiceClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)

Start mocks base method

func (*MockEventServiceClient) Stop 

func (m *MockEventServiceClient) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)

Stop mocks base method

func (*MockEventServiceClient) Subscribe 

func (m *MockEventServiceClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)

Subscribe mocks base method

type MockEventServiceClientMockRecorder 

type MockEventServiceClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockEventServiceClientMockRecorder is the mock recorder for MockEventServiceClient

func (*MockEventServiceClientMockRecorder) Publish 

func (mr *MockEventServiceClientMockRecorder) Publish(ctx, in interface{}, opts ...interface{}) *gomock.Call

Publish indicates an expected call of Publish

func (*MockEventServiceClientMockRecorder) Start 

func (mr *MockEventServiceClientMockRecorder) Start(ctx, in interface{}, opts ...interface{}) *gomock.Call

Start indicates an expected call of Start

func (*MockEventServiceClientMockRecorder) Stop 

func (mr *MockEventServiceClientMockRecorder) Stop(ctx, in interface{}, opts ...interface{}) *gomock.Call

Stop indicates an expected call of Stop

func (*MockEventServiceClientMockRecorder) Subscribe 

func (mr *MockEventServiceClientMockRecorder) Subscribe(ctx, in interface{}, opts ...interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe

type MockEventServiceServer 

type MockEventServiceServer struct {
	// contains filtered or unexported fields
}

MockEventServiceServer is a mock of EventServiceServer interface

func NewMockEventServiceServer 

func NewMockEventServiceServer(ctrl *gomock.Controller) *MockEventServiceServer

NewMockEventServiceServer creates a new mock instance

func (*MockEventServiceServer) EXPECT 

func (m *MockEventServiceServer) EXPECT() *MockEventServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockEventServiceServer) Publish 

func (m *MockEventServiceServer) Publish(arg0 context.Context, arg1 *PublishRequest) (*PublishResponse, error)

Publish mocks base method

func (*MockEventServiceServer) Start 

func (m *MockEventServiceServer) Start(arg0 context.Context, arg1 *StartRequest) (*StartResponse, error)

Start mocks base method

func (*MockEventServiceServer) Stop 

func (m *MockEventServiceServer) Stop(arg0 context.Context, arg1 *StopRequest) (*StopResponse, error)

Stop mocks base method

func (*MockEventServiceServer) Subscribe 

func (m *MockEventServiceServer) Subscribe(arg0 context.Context, arg1 *SubscribeRequest) (*SubscribeResponse, error)

Subscribe mocks base method

type MockEventServiceServerMockRecorder 

type MockEventServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockEventServiceServerMockRecorder is the mock recorder for MockEventServiceServer

func (*MockEventServiceServerMockRecorder) Publish 

func (mr *MockEventServiceServerMockRecorder) Publish(arg0, arg1 interface{}) *gomock.Call

Publish indicates an expected call of Publish

func (*MockEventServiceServerMockRecorder) Start 

func (mr *MockEventServiceServerMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call

Start indicates an expected call of Start

func (*MockEventServiceServerMockRecorder) Stop 

func (mr *MockEventServiceServerMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call

Stop indicates an expected call of Stop

func (*MockEventServiceServerMockRecorder) Subscribe 

func (mr *MockEventServiceServerMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe

type Object 

type Object struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty" toml:"ID,omitempty" mapstructure:"ID,omitempty"`
	ObjectType           string   `` /* 137-byte string literal not displayed */
	DisplayName          string   `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*Object) Descriptor 

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

func (*Object) GetDisplayName 

func (m *Object) GetDisplayName() string

func (*Object) GetID 

func (m *Object) GetID() string

func (*Object) GetObjectType 

func (m *Object) GetObjectType() string

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) String 

func (m *Object) String() string

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

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

func (*Object) XXX_Merge 

func (dst *Object) XXX_Merge(src proto.Message)

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

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

type Producer 

type Producer struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty" toml:"ID,omitempty" mapstructure:"ID,omitempty"`
	ProducerName         string   `` /* 145-byte string literal not displayed */
	ProducerType         string   `` /* 145-byte string literal not displayed */
	Tags                 []string `protobuf:"bytes,4,rep,name=Tags,proto3" json:"Tags,omitempty" toml:"Tags,omitempty" mapstructure:"Tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*Producer) Descriptor 

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

func (*Producer) GetID 

func (m *Producer) GetID() string

func (*Producer) GetProducerName 

func (m *Producer) GetProducerName() string

func (*Producer) GetProducerType 

func (m *Producer) GetProducerType() string

func (*Producer) GetTags 

func (m *Producer) GetTags() []string

func (*Producer) ProtoMessage 

func (*Producer) ProtoMessage()

func (*Producer) Reset 

func (m *Producer) Reset()

func (*Producer) String 

func (m *Producer) String() string

func (*Producer) XXX_DiscardUnknown 

func (m *Producer) XXX_DiscardUnknown()

func (*Producer) XXX_Marshal 

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

func (*Producer) XXX_Merge 

func (dst *Producer) XXX_Merge(src proto.Message)

func (*Producer) XXX_Size 

func (m *Producer) XXX_Size() int

func (*Producer) XXX_Unmarshal 

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

type PublishRequest 

type PublishRequest struct {
	Msg                  *EventMsg `protobuf:"bytes,1,opt,name=Msg,proto3" json:"Msg,omitempty" toml:"Msg,omitempty" mapstructure:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte    `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32     `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetMsg 

func (m *PublishRequest) GetMsg() *EventMsg

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

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

func (*PublishRequest) XXX_Merge 

func (dst *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

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

type PublishResponse 

type PublishResponse struct {
	Success              bool     `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*PublishResponse) Descriptor 

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

func (*PublishResponse) GetSuccess 

func (m *PublishResponse) GetSuccess() bool

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) Reset 

func (m *PublishResponse) Reset()

func (*PublishResponse) String 

func (m *PublishResponse) String() string

func (*PublishResponse) XXX_DiscardUnknown 

func (m *PublishResponse) XXX_DiscardUnknown()

func (*PublishResponse) XXX_Marshal 

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

func (*PublishResponse) XXX_Merge 

func (dst *PublishResponse) XXX_Merge(src proto.Message)

func (*PublishResponse) XXX_Size 

func (m *PublishResponse) XXX_Size() int

func (*PublishResponse) XXX_Unmarshal 

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

type StartRequest 

type StartRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartRequest) Descriptor 

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

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

func (*StartRequest) XXX_DiscardUnknown 

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal 

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

func (*StartRequest) XXX_Merge 

func (dst *StartRequest) XXX_Merge(src proto.Message)

func (*StartRequest) XXX_Size 

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal 

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

type StartResponse 

type StartResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartResponse) Descriptor 

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

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset 

func (m *StartResponse) Reset()

func (*StartResponse) String 

func (m *StartResponse) String() string

func (*StartResponse) XXX_DiscardUnknown 

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal 

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

func (*StartResponse) XXX_Merge 

func (dst *StartResponse) XXX_Merge(src proto.Message)

func (*StartResponse) XXX_Size 

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal 

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

type StopRequest 

type StopRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopRequest) Descriptor 

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

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) String 

func (m *StopRequest) String() string

func (*StopRequest) XXX_DiscardUnknown 

func (m *StopRequest) XXX_DiscardUnknown()

func (*StopRequest) XXX_Marshal 

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

func (*StopRequest) XXX_Merge 

func (dst *StopRequest) XXX_Merge(src proto.Message)

func (*StopRequest) XXX_Size 

func (m *StopRequest) XXX_Size() int

func (*StopRequest) XXX_Unmarshal 

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

type StopResponse 

type StopResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopResponse) Descriptor 

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

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) Reset 

func (m *StopResponse) Reset()

func (*StopResponse) String 

func (m *StopResponse) String() string

func (*StopResponse) XXX_DiscardUnknown 

func (m *StopResponse) XXX_DiscardUnknown()

func (*StopResponse) XXX_Marshal 

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

func (*StopResponse) XXX_Merge 

func (dst *StopResponse) XXX_Merge(src proto.Message)

func (*StopResponse) XXX_Size 

func (m *StopResponse) XXX_Size() int

func (*StopResponse) XXX_Unmarshal 

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

type SubscribeRequest 

type SubscribeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

func (dst *SubscribeRequest) XXX_Merge(src proto.Message)

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type SubscribeResponse 

type SubscribeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*SubscribeResponse) Descriptor 

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

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) XXX_DiscardUnknown 

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal 

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

func (*SubscribeResponse) XXX_Merge 

func (dst *SubscribeResponse) XXX_Merge(src proto.Message)

func (*SubscribeResponse) XXX_Size 

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal 

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

type Target 

type Target struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty" toml:"ID,omitempty" mapstructure:"ID,omitempty"`
	ObjectType           string   `` /* 137-byte string literal not displayed */
	DisplayName          string   `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*Target) Descriptor 

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

func (*Target) GetDisplayName 

func (m *Target) GetDisplayName() string

func (*Target) GetID 

func (m *Target) GetID() string

func (*Target) GetObjectType 

func (m *Target) GetObjectType() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) Reset 

func (m *Target) Reset()

func (*Target) String 

func (m *Target) String() string

func (*Target) XXX_DiscardUnknown 

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal 

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

func (*Target) XXX_Merge 

func (dst *Target) XXX_Merge(src proto.Message)

func (*Target) XXX_Size 

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal 

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