Documentation ¶
Index ¶
- func RegisterModuleServiceServer(s *grpc.Server, srv ModuleServiceServer)
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type ModuleCreateRequest
- func (*ModuleCreateRequest) Descriptor() ([]byte, []int)
- func (m *ModuleCreateRequest) GetConfigmap() map[string]string
- func (m *ModuleCreateRequest) GetEventpublications() string
- func (m *ModuleCreateRequest) GetEventsubscriptions() string
- func (m *ModuleCreateRequest) GetHandlerimage() string
- func (m *ModuleCreateRequest) GetInstancecount() int32
- func (m *ModuleCreateRequest) GetModuleimage() string
- func (m *ModuleCreateRequest) GetModulename() string
- func (m *ModuleCreateRequest) GetProvider() string
- func (m *ModuleCreateRequest) GetRetrycount() int32
- func (*ModuleCreateRequest) ProtoMessage()
- func (m *ModuleCreateRequest) Reset()
- func (m *ModuleCreateRequest) String() string
- func (m *ModuleCreateRequest) XXX_DiscardUnknown()
- func (m *ModuleCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleCreateRequest) XXX_Merge(src proto.Message)
- func (m *ModuleCreateRequest) XXX_Size() int
- func (m *ModuleCreateRequest) XXX_Unmarshal(b []byte) error
- type ModuleCreateResponse
- func (*ModuleCreateResponse) Descriptor() ([]byte, []int)
- func (m *ModuleCreateResponse) GetName() string
- func (*ModuleCreateResponse) ProtoMessage()
- func (m *ModuleCreateResponse) Reset()
- func (m *ModuleCreateResponse) String() string
- func (m *ModuleCreateResponse) XXX_DiscardUnknown()
- func (m *ModuleCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleCreateResponse) XXX_Merge(src proto.Message)
- func (m *ModuleCreateResponse) XXX_Size() int
- func (m *ModuleCreateResponse) XXX_Unmarshal(b []byte) error
- type ModuleDeleteRequest
- func (*ModuleDeleteRequest) Descriptor() ([]byte, []int)
- func (m *ModuleDeleteRequest) GetName() string
- func (*ModuleDeleteRequest) ProtoMessage()
- func (m *ModuleDeleteRequest) Reset()
- func (m *ModuleDeleteRequest) String() string
- func (m *ModuleDeleteRequest) XXX_DiscardUnknown()
- func (m *ModuleDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleDeleteRequest) XXX_Merge(src proto.Message)
- func (m *ModuleDeleteRequest) XXX_Size() int
- func (m *ModuleDeleteRequest) XXX_Unmarshal(b []byte) error
- type ModuleDeleteResponse
- func (*ModuleDeleteResponse) Descriptor() ([]byte, []int)
- func (m *ModuleDeleteResponse) GetName() string
- func (*ModuleDeleteResponse) ProtoMessage()
- func (m *ModuleDeleteResponse) Reset()
- func (m *ModuleDeleteResponse) String() string
- func (m *ModuleDeleteResponse) XXX_DiscardUnknown()
- func (m *ModuleDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleDeleteResponse) XXX_Merge(src proto.Message)
- func (m *ModuleDeleteResponse) XXX_Size() int
- func (m *ModuleDeleteResponse) XXX_Unmarshal(b []byte) error
- type ModuleGetRequest
- func (*ModuleGetRequest) Descriptor() ([]byte, []int)
- func (m *ModuleGetRequest) GetName() string
- func (*ModuleGetRequest) ProtoMessage()
- func (m *ModuleGetRequest) Reset()
- func (m *ModuleGetRequest) String() string
- func (m *ModuleGetRequest) XXX_DiscardUnknown()
- func (m *ModuleGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleGetRequest) XXX_Merge(src proto.Message)
- func (m *ModuleGetRequest) XXX_Size() int
- func (m *ModuleGetRequest) XXX_Unmarshal(b []byte) error
- type ModuleGetResponse
- func (*ModuleGetResponse) Descriptor() ([]byte, []int)
- func (m *ModuleGetResponse) GetName() string
- func (m *ModuleGetResponse) GetStatus() string
- func (m *ModuleGetResponse) GetStatusMessage() string
- func (*ModuleGetResponse) ProtoMessage()
- func (m *ModuleGetResponse) Reset()
- func (m *ModuleGetResponse) String() string
- func (m *ModuleGetResponse) XXX_DiscardUnknown()
- func (m *ModuleGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleGetResponse) XXX_Merge(src proto.Message)
- func (m *ModuleGetResponse) XXX_Size() int
- func (m *ModuleGetResponse) XXX_Unmarshal(b []byte) error
- type ModuleListRequest
- func (*ModuleListRequest) Descriptor() ([]byte, []int)
- func (*ModuleListRequest) ProtoMessage()
- func (m *ModuleListRequest) Reset()
- func (m *ModuleListRequest) String() string
- func (m *ModuleListRequest) XXX_DiscardUnknown()
- func (m *ModuleListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleListRequest) XXX_Merge(src proto.Message)
- func (m *ModuleListRequest) XXX_Size() int
- func (m *ModuleListRequest) XXX_Unmarshal(b []byte) error
- type ModuleListResponse
- func (*ModuleListResponse) Descriptor() ([]byte, []int)
- func (m *ModuleListResponse) GetNames() []string
- func (*ModuleListResponse) ProtoMessage()
- func (m *ModuleListResponse) Reset()
- func (m *ModuleListResponse) String() string
- func (m *ModuleListResponse) XXX_DiscardUnknown()
- func (m *ModuleListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModuleListResponse) XXX_Merge(src proto.Message)
- func (m *ModuleListResponse) XXX_Size() int
- func (m *ModuleListResponse) XXX_Unmarshal(b []byte) error
- type ModuleServiceClient
- type ModuleServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterModuleServiceServer ¶
func RegisterModuleServiceServer(s *grpc.Server, srv ModuleServiceServer)
Types ¶
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type ModuleCreateRequest ¶
type ModuleCreateRequest struct { Modulename string `protobuf:"bytes,1,opt,name=modulename,proto3" json:"modulename,omitempty"` Eventsubscriptions string `protobuf:"bytes,2,opt,name=eventsubscriptions,proto3" json:"eventsubscriptions,omitempty"` Eventpublications string `protobuf:"bytes,3,opt,name=eventpublications,proto3" json:"eventpublications,omitempty"` Moduleimage string `protobuf:"bytes,4,opt,name=moduleimage,proto3" json:"moduleimage,omitempty"` Handlerimage string `protobuf:"bytes,5,opt,name=handlerimage,proto3" json:"handlerimage,omitempty"` Instancecount int32 `protobuf:"varint,6,opt,name=instancecount,proto3" json:"instancecount,omitempty"` Retrycount int32 `protobuf:"varint,7,opt,name=retrycount,proto3" json:"retrycount,omitempty"` Provider string `protobuf:"bytes,8,opt,name=provider,proto3" json:"provider,omitempty"` Configmap map[string]string `` /* 159-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModuleCreateRequest) Descriptor ¶
func (*ModuleCreateRequest) Descriptor() ([]byte, []int)
func (*ModuleCreateRequest) GetConfigmap ¶
func (m *ModuleCreateRequest) GetConfigmap() map[string]string
func (*ModuleCreateRequest) GetEventpublications ¶
func (m *ModuleCreateRequest) GetEventpublications() string
func (*ModuleCreateRequest) GetEventsubscriptions ¶
func (m *ModuleCreateRequest) GetEventsubscriptions() string
func (*ModuleCreateRequest) GetHandlerimage ¶
func (m *ModuleCreateRequest) GetHandlerimage() string
func (*ModuleCreateRequest) GetInstancecount ¶
func (m *ModuleCreateRequest) GetInstancecount() int32
func (*ModuleCreateRequest) GetModuleimage ¶
func (m *ModuleCreateRequest) GetModuleimage() string
func (*ModuleCreateRequest) GetModulename ¶
func (m *ModuleCreateRequest) GetModulename() string
func (*ModuleCreateRequest) GetProvider ¶
func (m *ModuleCreateRequest) GetProvider() string
func (*ModuleCreateRequest) GetRetrycount ¶
func (m *ModuleCreateRequest) GetRetrycount() int32
func (*ModuleCreateRequest) ProtoMessage ¶
func (*ModuleCreateRequest) ProtoMessage()
func (*ModuleCreateRequest) Reset ¶
func (m *ModuleCreateRequest) Reset()
func (*ModuleCreateRequest) String ¶
func (m *ModuleCreateRequest) String() string
func (*ModuleCreateRequest) XXX_DiscardUnknown ¶
func (m *ModuleCreateRequest) XXX_DiscardUnknown()
func (*ModuleCreateRequest) XXX_Marshal ¶
func (m *ModuleCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleCreateRequest) XXX_Merge ¶
func (dst *ModuleCreateRequest) XXX_Merge(src proto.Message)
func (*ModuleCreateRequest) XXX_Size ¶
func (m *ModuleCreateRequest) XXX_Size() int
func (*ModuleCreateRequest) XXX_Unmarshal ¶
func (m *ModuleCreateRequest) XXX_Unmarshal(b []byte) error
type ModuleCreateResponse ¶
type ModuleCreateResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModuleCreateResponse) Descriptor ¶
func (*ModuleCreateResponse) Descriptor() ([]byte, []int)
func (*ModuleCreateResponse) GetName ¶
func (m *ModuleCreateResponse) GetName() string
func (*ModuleCreateResponse) ProtoMessage ¶
func (*ModuleCreateResponse) ProtoMessage()
func (*ModuleCreateResponse) Reset ¶
func (m *ModuleCreateResponse) Reset()
func (*ModuleCreateResponse) String ¶
func (m *ModuleCreateResponse) String() string
func (*ModuleCreateResponse) XXX_DiscardUnknown ¶
func (m *ModuleCreateResponse) XXX_DiscardUnknown()
func (*ModuleCreateResponse) XXX_Marshal ¶
func (m *ModuleCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleCreateResponse) XXX_Merge ¶
func (dst *ModuleCreateResponse) XXX_Merge(src proto.Message)
func (*ModuleCreateResponse) XXX_Size ¶
func (m *ModuleCreateResponse) XXX_Size() int
func (*ModuleCreateResponse) XXX_Unmarshal ¶
func (m *ModuleCreateResponse) XXX_Unmarshal(b []byte) error
type ModuleDeleteRequest ¶
type ModuleDeleteRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModuleDeleteRequest) Descriptor ¶
func (*ModuleDeleteRequest) Descriptor() ([]byte, []int)
func (*ModuleDeleteRequest) GetName ¶
func (m *ModuleDeleteRequest) GetName() string
func (*ModuleDeleteRequest) ProtoMessage ¶
func (*ModuleDeleteRequest) ProtoMessage()
func (*ModuleDeleteRequest) Reset ¶
func (m *ModuleDeleteRequest) Reset()
func (*ModuleDeleteRequest) String ¶
func (m *ModuleDeleteRequest) String() string
func (*ModuleDeleteRequest) XXX_DiscardUnknown ¶
func (m *ModuleDeleteRequest) XXX_DiscardUnknown()
func (*ModuleDeleteRequest) XXX_Marshal ¶
func (m *ModuleDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleDeleteRequest) XXX_Merge ¶
func (dst *ModuleDeleteRequest) XXX_Merge(src proto.Message)
func (*ModuleDeleteRequest) XXX_Size ¶
func (m *ModuleDeleteRequest) XXX_Size() int
func (*ModuleDeleteRequest) XXX_Unmarshal ¶
func (m *ModuleDeleteRequest) XXX_Unmarshal(b []byte) error
type ModuleDeleteResponse ¶
type ModuleDeleteResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModuleDeleteResponse) Descriptor ¶
func (*ModuleDeleteResponse) Descriptor() ([]byte, []int)
func (*ModuleDeleteResponse) GetName ¶
func (m *ModuleDeleteResponse) GetName() string
func (*ModuleDeleteResponse) ProtoMessage ¶
func (*ModuleDeleteResponse) ProtoMessage()
func (*ModuleDeleteResponse) Reset ¶
func (m *ModuleDeleteResponse) Reset()
func (*ModuleDeleteResponse) String ¶
func (m *ModuleDeleteResponse) String() string
func (*ModuleDeleteResponse) XXX_DiscardUnknown ¶
func (m *ModuleDeleteResponse) XXX_DiscardUnknown()
func (*ModuleDeleteResponse) XXX_Marshal ¶
func (m *ModuleDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleDeleteResponse) XXX_Merge ¶
func (dst *ModuleDeleteResponse) XXX_Merge(src proto.Message)
func (*ModuleDeleteResponse) XXX_Size ¶
func (m *ModuleDeleteResponse) XXX_Size() int
func (*ModuleDeleteResponse) XXX_Unmarshal ¶
func (m *ModuleDeleteResponse) XXX_Unmarshal(b []byte) error
type ModuleGetRequest ¶
type ModuleGetRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModuleGetRequest) Descriptor ¶
func (*ModuleGetRequest) Descriptor() ([]byte, []int)
func (*ModuleGetRequest) GetName ¶
func (m *ModuleGetRequest) GetName() string
func (*ModuleGetRequest) ProtoMessage ¶
func (*ModuleGetRequest) ProtoMessage()
func (*ModuleGetRequest) Reset ¶
func (m *ModuleGetRequest) Reset()
func (*ModuleGetRequest) String ¶
func (m *ModuleGetRequest) String() string
func (*ModuleGetRequest) XXX_DiscardUnknown ¶
func (m *ModuleGetRequest) XXX_DiscardUnknown()
func (*ModuleGetRequest) XXX_Marshal ¶
func (m *ModuleGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleGetRequest) XXX_Merge ¶
func (dst *ModuleGetRequest) XXX_Merge(src proto.Message)
func (*ModuleGetRequest) XXX_Size ¶
func (m *ModuleGetRequest) XXX_Size() int
func (*ModuleGetRequest) XXX_Unmarshal ¶
func (m *ModuleGetRequest) XXX_Unmarshal(b []byte) error
type ModuleGetResponse ¶
type ModuleGetResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` StatusMessage string `protobuf:"bytes,3,opt,name=statusMessage,proto3" json:"statusMessage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TODO: add more fields
func (*ModuleGetResponse) Descriptor ¶
func (*ModuleGetResponse) Descriptor() ([]byte, []int)
func (*ModuleGetResponse) GetName ¶
func (m *ModuleGetResponse) GetName() string
func (*ModuleGetResponse) GetStatus ¶
func (m *ModuleGetResponse) GetStatus() string
func (*ModuleGetResponse) GetStatusMessage ¶
func (m *ModuleGetResponse) GetStatusMessage() string
func (*ModuleGetResponse) ProtoMessage ¶
func (*ModuleGetResponse) ProtoMessage()
func (*ModuleGetResponse) Reset ¶
func (m *ModuleGetResponse) Reset()
func (*ModuleGetResponse) String ¶
func (m *ModuleGetResponse) String() string
func (*ModuleGetResponse) XXX_DiscardUnknown ¶
func (m *ModuleGetResponse) XXX_DiscardUnknown()
func (*ModuleGetResponse) XXX_Marshal ¶
func (m *ModuleGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleGetResponse) XXX_Merge ¶
func (dst *ModuleGetResponse) XXX_Merge(src proto.Message)
func (*ModuleGetResponse) XXX_Size ¶
func (m *ModuleGetResponse) XXX_Size() int
func (*ModuleGetResponse) XXX_Unmarshal ¶
func (m *ModuleGetResponse) XXX_Unmarshal(b []byte) error
type ModuleListRequest ¶
type ModuleListRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModuleListRequest) Descriptor ¶
func (*ModuleListRequest) Descriptor() ([]byte, []int)
func (*ModuleListRequest) ProtoMessage ¶
func (*ModuleListRequest) ProtoMessage()
func (*ModuleListRequest) Reset ¶
func (m *ModuleListRequest) Reset()
func (*ModuleListRequest) String ¶
func (m *ModuleListRequest) String() string
func (*ModuleListRequest) XXX_DiscardUnknown ¶
func (m *ModuleListRequest) XXX_DiscardUnknown()
func (*ModuleListRequest) XXX_Marshal ¶
func (m *ModuleListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleListRequest) XXX_Merge ¶
func (dst *ModuleListRequest) XXX_Merge(src proto.Message)
func (*ModuleListRequest) XXX_Size ¶
func (m *ModuleListRequest) XXX_Size() int
func (*ModuleListRequest) XXX_Unmarshal ¶
func (m *ModuleListRequest) XXX_Unmarshal(b []byte) error
type ModuleListResponse ¶
type ModuleListResponse struct { Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModuleListResponse) Descriptor ¶
func (*ModuleListResponse) Descriptor() ([]byte, []int)
func (*ModuleListResponse) GetNames ¶
func (m *ModuleListResponse) GetNames() []string
func (*ModuleListResponse) ProtoMessage ¶
func (*ModuleListResponse) ProtoMessage()
func (*ModuleListResponse) Reset ¶
func (m *ModuleListResponse) Reset()
func (*ModuleListResponse) String ¶
func (m *ModuleListResponse) String() string
func (*ModuleListResponse) XXX_DiscardUnknown ¶
func (m *ModuleListResponse) XXX_DiscardUnknown()
func (*ModuleListResponse) XXX_Marshal ¶
func (m *ModuleListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleListResponse) XXX_Merge ¶
func (dst *ModuleListResponse) XXX_Merge(src proto.Message)
func (*ModuleListResponse) XXX_Size ¶
func (m *ModuleListResponse) XXX_Size() int
func (*ModuleListResponse) XXX_Unmarshal ¶
func (m *ModuleListResponse) XXX_Unmarshal(b []byte) error
type ModuleServiceClient ¶
type ModuleServiceClient interface { Create(ctx context.Context, in *ModuleCreateRequest, opts ...grpc.CallOption) (*ModuleCreateResponse, error) Delete(ctx context.Context, in *ModuleDeleteRequest, opts ...grpc.CallOption) (*ModuleDeleteResponse, error) Get(ctx context.Context, in *ModuleGetRequest, opts ...grpc.CallOption) (*ModuleGetResponse, error) List(ctx context.Context, in *ModuleListRequest, opts ...grpc.CallOption) (*ModuleListResponse, error) }
ModuleServiceClient is the client API for ModuleService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewModuleServiceClient ¶
func NewModuleServiceClient(cc *grpc.ClientConn) ModuleServiceClient
type ModuleServiceServer ¶
type ModuleServiceServer interface { Create(context.Context, *ModuleCreateRequest) (*ModuleCreateResponse, error) Delete(context.Context, *ModuleDeleteRequest) (*ModuleDeleteResponse, error) Get(context.Context, *ModuleGetRequest) (*ModuleGetResponse, error) List(context.Context, *ModuleListRequest) (*ModuleListResponse, error) }
ModuleServiceServer is the server API for ModuleService service.
Click to show internal directories.
Click to hide internal directories.