Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterHostServiceServer(s grpc.ServiceRegistrar, srv HostServiceServer)
- func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)
- type CallRequest
- func (*CallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CallRequest) GetOperation() string
- func (x *CallRequest) GetParams() string
- func (*CallRequest) ProtoMessage()
- func (x *CallRequest) ProtoReflect() protoreflect.Message
- func (x *CallRequest) Reset()
- func (x *CallRequest) String() string
- type CallResponse
- func (*CallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CallResponse) GetError() string
- func (x *CallResponse) GetResult() string
- func (*CallResponse) ProtoMessage()
- func (x *CallResponse) ProtoReflect() protoreflect.Message
- func (x *CallResponse) Reset()
- func (x *CallResponse) String() string
- type CommandRequest
- func (*CommandRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CommandRequest) GetContent() string
- func (x *CommandRequest) GetContext() string
- func (*CommandRequest) ProtoMessage()
- func (x *CommandRequest) ProtoReflect() protoreflect.Message
- func (x *CommandRequest) Reset()
- func (x *CommandRequest) String() string
- type CommandResponse
- func (*CommandResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CommandResponse) GetError() string
- func (x *CommandResponse) GetPayload() string
- func (*CommandResponse) ProtoMessage()
- func (x *CommandResponse) ProtoReflect() protoreflect.Message
- func (x *CommandResponse) Reset()
- func (x *CommandResponse) String() string
- type EmitEventRequest
- func (*EmitEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EmitEventRequest) GetEventType() string
- func (x *EmitEventRequest) GetPayload() string
- func (x *EmitEventRequest) GetSource() string
- func (*EmitEventRequest) ProtoMessage()
- func (x *EmitEventRequest) ProtoReflect() protoreflect.Message
- func (x *EmitEventRequest) Reset()
- func (x *EmitEventRequest) String() string
- type FormRequest
- func (*FormRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FormRequest) GetContext() string
- func (x *FormRequest) GetValues() map[string]string
- func (*FormRequest) ProtoMessage()
- func (x *FormRequest) ProtoReflect() protoreflect.Message
- func (x *FormRequest) Reset()
- func (x *FormRequest) String() string
- type FormResponse
- func (*FormResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FormResponse) GetError() string
- func (x *FormResponse) GetPayload() string
- func (*FormResponse) ProtoMessage()
- func (x *FormResponse) ProtoReflect() protoreflect.Message
- func (x *FormResponse) Reset()
- func (x *FormResponse) String() string
- type GetConfigRequest
- type GetConfigResponse
- func (*GetConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigResponse) GetError() string
- func (x *GetConfigResponse) GetValue() string
- func (*GetConfigResponse) ProtoMessage()
- func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetConfigResponse) Reset()
- func (x *GetConfigResponse) String() string
- type HTTPCallRequest
- func (*HTTPCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HTTPCallRequest) GetBody() []byte
- func (x *HTTPCallRequest) GetHeaders() map[string]string
- func (x *HTTPCallRequest) GetMethod() string
- func (x *HTTPCallRequest) GetUrl() string
- func (*HTTPCallRequest) ProtoMessage()
- func (x *HTTPCallRequest) ProtoReflect() protoreflect.Message
- func (x *HTTPCallRequest) Reset()
- func (x *HTTPCallRequest) String() string
- type HTTPCallResponse
- func (*HTTPCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HTTPCallResponse) GetBody() []byte
- func (x *HTTPCallResponse) GetError() string
- func (x *HTTPCallResponse) GetHeaders() map[string]string
- func (x *HTTPCallResponse) GetStatus() int32
- func (*HTTPCallResponse) ProtoMessage()
- func (x *HTTPCallResponse) ProtoReflect() protoreflect.Message
- func (x *HTTPCallResponse) Reset()
- func (x *HTTPCallResponse) String() string
- type HelpResponse
- func (*HelpResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HelpResponse) GetError() string
- func (x *HelpResponse) GetHelp() string
- func (*HelpResponse) ProtoMessage()
- func (x *HelpResponse) ProtoReflect() protoreflect.Message
- func (x *HelpResponse) Reset()
- func (x *HelpResponse) String() string
- type HostServiceClient
- type HostServiceServer
- type InitRequest
- type InitResponse
- type IsReadyResponse
- type KVDeleteRequest
- type KVGetRequest
- type KVGetResponse
- func (*KVGetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *KVGetResponse) GetError() string
- func (x *KVGetResponse) GetValue() []byte
- func (*KVGetResponse) ProtoMessage()
- func (x *KVGetResponse) ProtoReflect() protoreflect.Message
- func (x *KVGetResponse) Reset()
- func (x *KVGetResponse) String() string
- type KVSetRequest
- func (*KVSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KVSetRequest) GetKey() string
- func (x *KVSetRequest) GetValue() []byte
- func (*KVSetRequest) ProtoMessage()
- func (x *KVSetRequest) ProtoReflect() protoreflect.Message
- func (x *KVSetRequest) Reset()
- func (x *KVSetRequest) String() string
- type LogRequest
- func (*LogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogRequest) GetFields() map[string]string
- func (x *LogRequest) GetLevel() string
- func (x *LogRequest) GetMessage() string
- func (*LogRequest) ProtoMessage()
- func (x *LogRequest) ProtoReflect() protoreflect.Message
- func (x *LogRequest) Reset()
- func (x *LogRequest) String() string
- type OAuthCallbackRequest
- func (*OAuthCallbackRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OAuthCallbackRequest) GetCode() string
- func (x *OAuthCallbackRequest) GetState() string
- func (*OAuthCallbackRequest) ProtoMessage()
- func (x *OAuthCallbackRequest) ProtoReflect() protoreflect.Message
- func (x *OAuthCallbackRequest) Reset()
- func (x *OAuthCallbackRequest) String() string
- type PluginServiceClient
- type PluginServiceServer
- type RulesResponse
- func (*RulesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RulesResponse) GetError() string
- func (x *RulesResponse) GetRules() string
- func (*RulesResponse) ProtoMessage()
- func (x *RulesResponse) ProtoReflect() protoreflect.Message
- func (x *RulesResponse) Reset()
- func (x *RulesResponse) String() string
- type UnimplementedHostServiceServer
- func (UnimplementedHostServiceServer) EmitEvent(context.Context, *EmitEventRequest) (*emptypb.Empty, error)
- func (UnimplementedHostServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
- func (UnimplementedHostServiceServer) HTTPRequest(context.Context, *HTTPCallRequest) (*HTTPCallResponse, error)
- func (UnimplementedHostServiceServer) KVDelete(context.Context, *KVDeleteRequest) (*emptypb.Empty, error)
- func (UnimplementedHostServiceServer) KVGet(context.Context, *KVGetRequest) (*KVGetResponse, error)
- func (UnimplementedHostServiceServer) KVSet(context.Context, *KVSetRequest) (*emptypb.Empty, error)
- func (UnimplementedHostServiceServer) Log(context.Context, *LogRequest) (*emptypb.Empty, error)
- type UnimplementedPluginServiceServer
- func (UnimplementedPluginServiceServer) AbilityCall(context.Context, *CallRequest) (*CallResponse, error)
- func (UnimplementedPluginServiceServer) Bootstrap(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedPluginServiceServer) Command(context.Context, *CommandRequest) (*CommandResponse, error)
- func (UnimplementedPluginServiceServer) Form(context.Context, *FormRequest) (*FormResponse, error)
- func (UnimplementedPluginServiceServer) Help(context.Context, *emptypb.Empty) (*HelpResponse, error)
- func (UnimplementedPluginServiceServer) Init(context.Context, *InitRequest) (*InitResponse, error)
- func (UnimplementedPluginServiceServer) IsReady(context.Context, *emptypb.Empty) (*IsReadyResponse, error)
- func (UnimplementedPluginServiceServer) OAuthCallback(context.Context, *OAuthCallbackRequest) (*CallResponse, error)
- func (UnimplementedPluginServiceServer) Rules(context.Context, *emptypb.Empty) (*RulesResponse, error)
- func (UnimplementedPluginServiceServer) WebhookConvert(context.Context, *WebhookConvertRequest) (*CallResponse, error)
- type UnsafeHostServiceServer
- type UnsafePluginServiceServer
- type WebhookConvertRequest
- func (*WebhookConvertRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WebhookConvertRequest) GetPayload() []byte
- func (*WebhookConvertRequest) ProtoMessage()
- func (x *WebhookConvertRequest) ProtoReflect() protoreflect.Message
- func (x *WebhookConvertRequest) Reset()
- func (x *WebhookConvertRequest) String() string
Constants ¶
const ( PluginService_Init_FullMethodName = "/flowbot.plugin.PluginService/Init" PluginService_Bootstrap_FullMethodName = "/flowbot.plugin.PluginService/Bootstrap" PluginService_Command_FullMethodName = "/flowbot.plugin.PluginService/Command" PluginService_Form_FullMethodName = "/flowbot.plugin.PluginService/Form" PluginService_Rules_FullMethodName = "/flowbot.plugin.PluginService/Rules" PluginService_Help_FullMethodName = "/flowbot.plugin.PluginService/Help" PluginService_IsReady_FullMethodName = "/flowbot.plugin.PluginService/IsReady" PluginService_AbilityCall_FullMethodName = "/flowbot.plugin.PluginService/AbilityCall" PluginService_WebhookConvert_FullMethodName = "/flowbot.plugin.PluginService/WebhookConvert" PluginService_OAuthCallback_FullMethodName = "/flowbot.plugin.PluginService/OAuthCallback" )
const ( HostService_GetConfig_FullMethodName = "/flowbot.plugin.HostService/GetConfig" HostService_Log_FullMethodName = "/flowbot.plugin.HostService/Log" HostService_KVGet_FullMethodName = "/flowbot.plugin.HostService/KVGet" HostService_KVSet_FullMethodName = "/flowbot.plugin.HostService/KVSet" HostService_KVDelete_FullMethodName = "/flowbot.plugin.HostService/KVDelete" HostService_HTTPRequest_FullMethodName = "/flowbot.plugin.HostService/HTTPRequest" HostService_EmitEvent_FullMethodName = "/flowbot.plugin.HostService/EmitEvent" )
Variables ¶
var File_pkg_plugin_grpc_proto_plugin_proto protoreflect.FileDescriptor
var HostService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "flowbot.plugin.HostService", HandlerType: (*HostServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetConfig", Handler: _HostService_GetConfig_Handler, }, { MethodName: "Log", Handler: _HostService_Log_Handler, }, { MethodName: "KVGet", Handler: _HostService_KVGet_Handler, }, { MethodName: "KVSet", Handler: _HostService_KVSet_Handler, }, { MethodName: "KVDelete", Handler: _HostService_KVDelete_Handler, }, { MethodName: "HTTPRequest", Handler: _HostService_HTTPRequest_Handler, }, { MethodName: "EmitEvent", Handler: _HostService_EmitEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/plugin/grpc/proto/plugin.proto", }
HostService_ServiceDesc is the grpc.ServiceDesc for HostService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var PluginService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "flowbot.plugin.PluginService", HandlerType: (*PluginServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Init", Handler: _PluginService_Init_Handler, }, { MethodName: "Bootstrap", Handler: _PluginService_Bootstrap_Handler, }, { MethodName: "Command", Handler: _PluginService_Command_Handler, }, { MethodName: "Form", Handler: _PluginService_Form_Handler, }, { MethodName: "Rules", Handler: _PluginService_Rules_Handler, }, { MethodName: "Help", Handler: _PluginService_Help_Handler, }, { MethodName: "IsReady", Handler: _PluginService_IsReady_Handler, }, { MethodName: "AbilityCall", Handler: _PluginService_AbilityCall_Handler, }, { MethodName: "WebhookConvert", Handler: _PluginService_WebhookConvert_Handler, }, { MethodName: "OAuthCallback", Handler: _PluginService_OAuthCallback_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/plugin/grpc/proto/plugin.proto", }
PluginService_ServiceDesc is the grpc.ServiceDesc for PluginService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterHostServiceServer ¶
func RegisterHostServiceServer(s grpc.ServiceRegistrar, srv HostServiceServer)
func RegisterPluginServiceServer ¶
func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)
Types ¶
type CallRequest ¶
type CallRequest struct {
Operation string `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
Params string `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"` // JSON-encoded params
// contains filtered or unexported fields
}
func (*CallRequest) Descriptor
deprecated
func (*CallRequest) Descriptor() ([]byte, []int)
Deprecated: Use CallRequest.ProtoReflect.Descriptor instead.
func (*CallRequest) GetOperation ¶
func (x *CallRequest) GetOperation() string
func (*CallRequest) GetParams ¶
func (x *CallRequest) GetParams() string
func (*CallRequest) ProtoMessage ¶
func (*CallRequest) ProtoMessage()
func (*CallRequest) ProtoReflect ¶
func (x *CallRequest) ProtoReflect() protoreflect.Message
func (*CallRequest) Reset ¶
func (x *CallRequest) Reset()
func (*CallRequest) String ¶
func (x *CallRequest) String() string
type CallResponse ¶
type CallResponse struct {
Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // JSON-encoded result
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*CallResponse) Descriptor
deprecated
func (*CallResponse) Descriptor() ([]byte, []int)
Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.
func (*CallResponse) GetError ¶
func (x *CallResponse) GetError() string
func (*CallResponse) GetResult ¶
func (x *CallResponse) GetResult() string
func (*CallResponse) ProtoMessage ¶
func (*CallResponse) ProtoMessage()
func (*CallResponse) ProtoReflect ¶
func (x *CallResponse) ProtoReflect() protoreflect.Message
func (*CallResponse) Reset ¶
func (x *CallResponse) Reset()
func (*CallResponse) String ¶
func (x *CallResponse) String() string
type CommandRequest ¶
type CommandRequest struct {
Context string `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` // JSON-encoded types.Context
Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // JSON-encoded content
// contains filtered or unexported fields
}
func (*CommandRequest) Descriptor
deprecated
func (*CommandRequest) Descriptor() ([]byte, []int)
Deprecated: Use CommandRequest.ProtoReflect.Descriptor instead.
func (*CommandRequest) GetContent ¶
func (x *CommandRequest) GetContent() string
func (*CommandRequest) GetContext ¶
func (x *CommandRequest) GetContext() string
func (*CommandRequest) ProtoMessage ¶
func (*CommandRequest) ProtoMessage()
func (*CommandRequest) ProtoReflect ¶
func (x *CommandRequest) ProtoReflect() protoreflect.Message
func (*CommandRequest) Reset ¶
func (x *CommandRequest) Reset()
func (*CommandRequest) String ¶
func (x *CommandRequest) String() string
type CommandResponse ¶
type CommandResponse struct {
Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // JSON-encoded types.MsgPayload
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*CommandResponse) Descriptor
deprecated
func (*CommandResponse) Descriptor() ([]byte, []int)
Deprecated: Use CommandResponse.ProtoReflect.Descriptor instead.
func (*CommandResponse) GetError ¶
func (x *CommandResponse) GetError() string
func (*CommandResponse) GetPayload ¶
func (x *CommandResponse) GetPayload() string
func (*CommandResponse) ProtoMessage ¶
func (*CommandResponse) ProtoMessage()
func (*CommandResponse) ProtoReflect ¶
func (x *CommandResponse) ProtoReflect() protoreflect.Message
func (*CommandResponse) Reset ¶
func (x *CommandResponse) Reset()
func (*CommandResponse) String ¶
func (x *CommandResponse) String() string
type EmitEventRequest ¶
type EmitEventRequest struct {
Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
EventType string `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // JSON-encoded
// contains filtered or unexported fields
}
func (*EmitEventRequest) Descriptor
deprecated
func (*EmitEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use EmitEventRequest.ProtoReflect.Descriptor instead.
func (*EmitEventRequest) GetEventType ¶
func (x *EmitEventRequest) GetEventType() string
func (*EmitEventRequest) GetPayload ¶
func (x *EmitEventRequest) GetPayload() string
func (*EmitEventRequest) GetSource ¶
func (x *EmitEventRequest) GetSource() string
func (*EmitEventRequest) ProtoMessage ¶
func (*EmitEventRequest) ProtoMessage()
func (*EmitEventRequest) ProtoReflect ¶
func (x *EmitEventRequest) ProtoReflect() protoreflect.Message
func (*EmitEventRequest) Reset ¶
func (x *EmitEventRequest) Reset()
func (*EmitEventRequest) String ¶
func (x *EmitEventRequest) String() string
type FormRequest ¶
type FormRequest struct {
Context string `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` // JSON-encoded types.Context
Values map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*FormRequest) Descriptor
deprecated
func (*FormRequest) Descriptor() ([]byte, []int)
Deprecated: Use FormRequest.ProtoReflect.Descriptor instead.
func (*FormRequest) GetContext ¶
func (x *FormRequest) GetContext() string
func (*FormRequest) GetValues ¶
func (x *FormRequest) GetValues() map[string]string
func (*FormRequest) ProtoMessage ¶
func (*FormRequest) ProtoMessage()
func (*FormRequest) ProtoReflect ¶
func (x *FormRequest) ProtoReflect() protoreflect.Message
func (*FormRequest) Reset ¶
func (x *FormRequest) Reset()
func (*FormRequest) String ¶
func (x *FormRequest) String() string
type FormResponse ¶
type FormResponse struct {
Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*FormResponse) Descriptor
deprecated
func (*FormResponse) Descriptor() ([]byte, []int)
Deprecated: Use FormResponse.ProtoReflect.Descriptor instead.
func (*FormResponse) GetError ¶
func (x *FormResponse) GetError() string
func (*FormResponse) GetPayload ¶
func (x *FormResponse) GetPayload() string
func (*FormResponse) ProtoMessage ¶
func (*FormResponse) ProtoMessage()
func (*FormResponse) ProtoReflect ¶
func (x *FormResponse) ProtoReflect() protoreflect.Message
func (*FormResponse) Reset ¶
func (x *FormResponse) Reset()
func (*FormResponse) String ¶
func (x *FormResponse) String() string
type GetConfigRequest ¶
type GetConfigRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*GetConfigRequest) Descriptor
deprecated
func (*GetConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.
func (*GetConfigRequest) GetKey ¶
func (x *GetConfigRequest) GetKey() string
func (*GetConfigRequest) ProtoMessage ¶
func (*GetConfigRequest) ProtoMessage()
func (*GetConfigRequest) ProtoReflect ¶
func (x *GetConfigRequest) ProtoReflect() protoreflect.Message
func (*GetConfigRequest) Reset ¶
func (x *GetConfigRequest) Reset()
func (*GetConfigRequest) String ¶
func (x *GetConfigRequest) String() string
type GetConfigResponse ¶
type GetConfigResponse struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*GetConfigResponse) Descriptor
deprecated
func (*GetConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.
func (*GetConfigResponse) GetError ¶
func (x *GetConfigResponse) GetError() string
func (*GetConfigResponse) GetValue ¶
func (x *GetConfigResponse) GetValue() string
func (*GetConfigResponse) ProtoMessage ¶
func (*GetConfigResponse) ProtoMessage()
func (*GetConfigResponse) ProtoReflect ¶
func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
func (*GetConfigResponse) Reset ¶
func (x *GetConfigResponse) Reset()
func (*GetConfigResponse) String ¶
func (x *GetConfigResponse) String() string
type HTTPCallRequest ¶
type HTTPCallRequest struct {
Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
Headers map[string]string `` /* 141-byte string literal not displayed */
Body []byte `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
// contains filtered or unexported fields
}
func (*HTTPCallRequest) Descriptor
deprecated
func (*HTTPCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use HTTPCallRequest.ProtoReflect.Descriptor instead.
func (*HTTPCallRequest) GetBody ¶
func (x *HTTPCallRequest) GetBody() []byte
func (*HTTPCallRequest) GetHeaders ¶
func (x *HTTPCallRequest) GetHeaders() map[string]string
func (*HTTPCallRequest) GetMethod ¶
func (x *HTTPCallRequest) GetMethod() string
func (*HTTPCallRequest) GetUrl ¶
func (x *HTTPCallRequest) GetUrl() string
func (*HTTPCallRequest) ProtoMessage ¶
func (*HTTPCallRequest) ProtoMessage()
func (*HTTPCallRequest) ProtoReflect ¶
func (x *HTTPCallRequest) ProtoReflect() protoreflect.Message
func (*HTTPCallRequest) Reset ¶
func (x *HTTPCallRequest) Reset()
func (*HTTPCallRequest) String ¶
func (x *HTTPCallRequest) String() string
type HTTPCallResponse ¶
type HTTPCallResponse struct {
Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
Headers map[string]string `` /* 141-byte string literal not displayed */
Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*HTTPCallResponse) Descriptor
deprecated
func (*HTTPCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use HTTPCallResponse.ProtoReflect.Descriptor instead.
func (*HTTPCallResponse) GetBody ¶
func (x *HTTPCallResponse) GetBody() []byte
func (*HTTPCallResponse) GetError ¶
func (x *HTTPCallResponse) GetError() string
func (*HTTPCallResponse) GetHeaders ¶
func (x *HTTPCallResponse) GetHeaders() map[string]string
func (*HTTPCallResponse) GetStatus ¶
func (x *HTTPCallResponse) GetStatus() int32
func (*HTTPCallResponse) ProtoMessage ¶
func (*HTTPCallResponse) ProtoMessage()
func (*HTTPCallResponse) ProtoReflect ¶
func (x *HTTPCallResponse) ProtoReflect() protoreflect.Message
func (*HTTPCallResponse) Reset ¶
func (x *HTTPCallResponse) Reset()
func (*HTTPCallResponse) String ¶
func (x *HTTPCallResponse) String() string
type HelpResponse ¶
type HelpResponse struct {
Help string `protobuf:"bytes,1,opt,name=help,proto3" json:"help,omitempty"` // JSON-encoded map[string][]string
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*HelpResponse) Descriptor
deprecated
func (*HelpResponse) Descriptor() ([]byte, []int)
Deprecated: Use HelpResponse.ProtoReflect.Descriptor instead.
func (*HelpResponse) GetError ¶
func (x *HelpResponse) GetError() string
func (*HelpResponse) GetHelp ¶
func (x *HelpResponse) GetHelp() string
func (*HelpResponse) ProtoMessage ¶
func (*HelpResponse) ProtoMessage()
func (*HelpResponse) ProtoReflect ¶
func (x *HelpResponse) ProtoReflect() protoreflect.Message
func (*HelpResponse) Reset ¶
func (x *HelpResponse) Reset()
func (*HelpResponse) String ¶
func (x *HelpResponse) String() string
type HostServiceClient ¶
type HostServiceClient interface {
GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
Log(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
KVGet(ctx context.Context, in *KVGetRequest, opts ...grpc.CallOption) (*KVGetResponse, error)
KVSet(ctx context.Context, in *KVSetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
KVDelete(ctx context.Context, in *KVDeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
HTTPRequest(ctx context.Context, in *HTTPCallRequest, opts ...grpc.CallOption) (*HTTPCallResponse, error)
EmitEvent(ctx context.Context, in *EmitEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
HostServiceClient is the client API for HostService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
HostService is exposed by flowbot to the plugin binary (Host API).
func NewHostServiceClient ¶
func NewHostServiceClient(cc grpc.ClientConnInterface) HostServiceClient
type HostServiceServer ¶
type HostServiceServer interface {
GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
Log(context.Context, *LogRequest) (*emptypb.Empty, error)
KVGet(context.Context, *KVGetRequest) (*KVGetResponse, error)
KVSet(context.Context, *KVSetRequest) (*emptypb.Empty, error)
KVDelete(context.Context, *KVDeleteRequest) (*emptypb.Empty, error)
HTTPRequest(context.Context, *HTTPCallRequest) (*HTTPCallResponse, error)
EmitEvent(context.Context, *EmitEventRequest) (*emptypb.Empty, error)
// contains filtered or unexported methods
}
HostServiceServer is the server API for HostService service. All implementations must embed UnimplementedHostServiceServer for forward compatibility.
HostService is exposed by flowbot to the plugin binary (Host API).
type InitRequest ¶
type InitRequest struct {
Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // JSON-encoded config
// contains filtered or unexported fields
}
func (*InitRequest) Descriptor
deprecated
func (*InitRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.
func (*InitRequest) GetConfig ¶
func (x *InitRequest) GetConfig() string
func (*InitRequest) ProtoMessage ¶
func (*InitRequest) ProtoMessage()
func (*InitRequest) ProtoReflect ¶
func (x *InitRequest) ProtoReflect() protoreflect.Message
func (*InitRequest) Reset ¶
func (x *InitRequest) Reset()
func (*InitRequest) String ¶
func (x *InitRequest) String() string
type InitResponse ¶
type InitResponse struct {
// contains filtered or unexported fields
}
func (*InitResponse) Descriptor
deprecated
func (*InitResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.
func (*InitResponse) ProtoMessage ¶
func (*InitResponse) ProtoMessage()
func (*InitResponse) ProtoReflect ¶
func (x *InitResponse) ProtoReflect() protoreflect.Message
func (*InitResponse) Reset ¶
func (x *InitResponse) Reset()
func (*InitResponse) String ¶
func (x *InitResponse) String() string
type IsReadyResponse ¶
type IsReadyResponse struct {
Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
// contains filtered or unexported fields
}
func (*IsReadyResponse) Descriptor
deprecated
func (*IsReadyResponse) Descriptor() ([]byte, []int)
Deprecated: Use IsReadyResponse.ProtoReflect.Descriptor instead.
func (*IsReadyResponse) GetReady ¶
func (x *IsReadyResponse) GetReady() bool
func (*IsReadyResponse) ProtoMessage ¶
func (*IsReadyResponse) ProtoMessage()
func (*IsReadyResponse) ProtoReflect ¶
func (x *IsReadyResponse) ProtoReflect() protoreflect.Message
func (*IsReadyResponse) Reset ¶
func (x *IsReadyResponse) Reset()
func (*IsReadyResponse) String ¶
func (x *IsReadyResponse) String() string
type KVDeleteRequest ¶
type KVDeleteRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*KVDeleteRequest) Descriptor
deprecated
func (*KVDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use KVDeleteRequest.ProtoReflect.Descriptor instead.
func (*KVDeleteRequest) GetKey ¶
func (x *KVDeleteRequest) GetKey() string
func (*KVDeleteRequest) ProtoMessage ¶
func (*KVDeleteRequest) ProtoMessage()
func (*KVDeleteRequest) ProtoReflect ¶
func (x *KVDeleteRequest) ProtoReflect() protoreflect.Message
func (*KVDeleteRequest) Reset ¶
func (x *KVDeleteRequest) Reset()
func (*KVDeleteRequest) String ¶
func (x *KVDeleteRequest) String() string
type KVGetRequest ¶
type KVGetRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*KVGetRequest) Descriptor
deprecated
func (*KVGetRequest) Descriptor() ([]byte, []int)
Deprecated: Use KVGetRequest.ProtoReflect.Descriptor instead.
func (*KVGetRequest) GetKey ¶
func (x *KVGetRequest) GetKey() string
func (*KVGetRequest) ProtoMessage ¶
func (*KVGetRequest) ProtoMessage()
func (*KVGetRequest) ProtoReflect ¶
func (x *KVGetRequest) ProtoReflect() protoreflect.Message
func (*KVGetRequest) Reset ¶
func (x *KVGetRequest) Reset()
func (*KVGetRequest) String ¶
func (x *KVGetRequest) String() string
type KVGetResponse ¶
type KVGetResponse struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*KVGetResponse) Descriptor
deprecated
func (*KVGetResponse) Descriptor() ([]byte, []int)
Deprecated: Use KVGetResponse.ProtoReflect.Descriptor instead.
func (*KVGetResponse) GetError ¶
func (x *KVGetResponse) GetError() string
func (*KVGetResponse) GetValue ¶
func (x *KVGetResponse) GetValue() []byte
func (*KVGetResponse) ProtoMessage ¶
func (*KVGetResponse) ProtoMessage()
func (*KVGetResponse) ProtoReflect ¶
func (x *KVGetResponse) ProtoReflect() protoreflect.Message
func (*KVGetResponse) Reset ¶
func (x *KVGetResponse) Reset()
func (*KVGetResponse) String ¶
func (x *KVGetResponse) String() string
type KVSetRequest ¶
type KVSetRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*KVSetRequest) Descriptor
deprecated
func (*KVSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use KVSetRequest.ProtoReflect.Descriptor instead.
func (*KVSetRequest) GetKey ¶
func (x *KVSetRequest) GetKey() string
func (*KVSetRequest) GetValue ¶
func (x *KVSetRequest) GetValue() []byte
func (*KVSetRequest) ProtoMessage ¶
func (*KVSetRequest) ProtoMessage()
func (*KVSetRequest) ProtoReflect ¶
func (x *KVSetRequest) ProtoReflect() protoreflect.Message
func (*KVSetRequest) Reset ¶
func (x *KVSetRequest) Reset()
func (*KVSetRequest) String ¶
func (x *KVSetRequest) String() string
type LogRequest ¶
type LogRequest struct {
Level string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Fields map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*LogRequest) Descriptor
deprecated
func (*LogRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.
func (*LogRequest) GetFields ¶
func (x *LogRequest) GetFields() map[string]string
func (*LogRequest) GetLevel ¶
func (x *LogRequest) GetLevel() string
func (*LogRequest) GetMessage ¶
func (x *LogRequest) GetMessage() string
func (*LogRequest) ProtoMessage ¶
func (*LogRequest) ProtoMessage()
func (*LogRequest) ProtoReflect ¶
func (x *LogRequest) ProtoReflect() protoreflect.Message
func (*LogRequest) Reset ¶
func (x *LogRequest) Reset()
func (*LogRequest) String ¶
func (x *LogRequest) String() string
type OAuthCallbackRequest ¶
type OAuthCallbackRequest struct {
State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
// contains filtered or unexported fields
}
func (*OAuthCallbackRequest) Descriptor
deprecated
func (*OAuthCallbackRequest) Descriptor() ([]byte, []int)
Deprecated: Use OAuthCallbackRequest.ProtoReflect.Descriptor instead.
func (*OAuthCallbackRequest) GetCode ¶
func (x *OAuthCallbackRequest) GetCode() string
func (*OAuthCallbackRequest) GetState ¶
func (x *OAuthCallbackRequest) GetState() string
func (*OAuthCallbackRequest) ProtoMessage ¶
func (*OAuthCallbackRequest) ProtoMessage()
func (*OAuthCallbackRequest) ProtoReflect ¶
func (x *OAuthCallbackRequest) ProtoReflect() protoreflect.Message
func (*OAuthCallbackRequest) Reset ¶
func (x *OAuthCallbackRequest) Reset()
func (*OAuthCallbackRequest) String ¶
func (x *OAuthCallbackRequest) String() string
type PluginServiceClient ¶
type PluginServiceClient interface {
Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
Bootstrap(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
Command(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (*CommandResponse, error)
Form(ctx context.Context, in *FormRequest, opts ...grpc.CallOption) (*FormResponse, error)
Rules(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RulesResponse, error)
Help(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HelpResponse, error)
IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IsReadyResponse, error)
AbilityCall(ctx context.Context, in *CallRequest, opts ...grpc.CallOption) (*CallResponse, error)
WebhookConvert(ctx context.Context, in *WebhookConvertRequest, opts ...grpc.CallOption) (*CallResponse, error)
OAuthCallback(ctx context.Context, in *OAuthCallbackRequest, opts ...grpc.CallOption) (*CallResponse, error)
}
PluginServiceClient is the client API for PluginService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
PluginService is exposed by the plugin binary to flowbot.
func NewPluginServiceClient ¶
func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient
type PluginServiceServer ¶
type PluginServiceServer interface {
Init(context.Context, *InitRequest) (*InitResponse, error)
Bootstrap(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
Command(context.Context, *CommandRequest) (*CommandResponse, error)
Form(context.Context, *FormRequest) (*FormResponse, error)
Rules(context.Context, *emptypb.Empty) (*RulesResponse, error)
Help(context.Context, *emptypb.Empty) (*HelpResponse, error)
IsReady(context.Context, *emptypb.Empty) (*IsReadyResponse, error)
AbilityCall(context.Context, *CallRequest) (*CallResponse, error)
WebhookConvert(context.Context, *WebhookConvertRequest) (*CallResponse, error)
OAuthCallback(context.Context, *OAuthCallbackRequest) (*CallResponse, error)
// contains filtered or unexported methods
}
PluginServiceServer is the server API for PluginService service. All implementations must embed UnimplementedPluginServiceServer for forward compatibility.
PluginService is exposed by the plugin binary to flowbot.
type RulesResponse ¶
type RulesResponse struct {
Rules string `protobuf:"bytes,1,opt,name=rules,proto3" json:"rules,omitempty"` // JSON-encoded []any
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*RulesResponse) Descriptor
deprecated
func (*RulesResponse) Descriptor() ([]byte, []int)
Deprecated: Use RulesResponse.ProtoReflect.Descriptor instead.
func (*RulesResponse) GetError ¶
func (x *RulesResponse) GetError() string
func (*RulesResponse) GetRules ¶
func (x *RulesResponse) GetRules() string
func (*RulesResponse) ProtoMessage ¶
func (*RulesResponse) ProtoMessage()
func (*RulesResponse) ProtoReflect ¶
func (x *RulesResponse) ProtoReflect() protoreflect.Message
func (*RulesResponse) Reset ¶
func (x *RulesResponse) Reset()
func (*RulesResponse) String ¶
func (x *RulesResponse) String() string
type UnimplementedHostServiceServer ¶
type UnimplementedHostServiceServer struct{}
UnimplementedHostServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedHostServiceServer) EmitEvent ¶
func (UnimplementedHostServiceServer) EmitEvent(context.Context, *EmitEventRequest) (*emptypb.Empty, error)
func (UnimplementedHostServiceServer) GetConfig ¶
func (UnimplementedHostServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
func (UnimplementedHostServiceServer) HTTPRequest ¶
func (UnimplementedHostServiceServer) HTTPRequest(context.Context, *HTTPCallRequest) (*HTTPCallResponse, error)
func (UnimplementedHostServiceServer) KVDelete ¶
func (UnimplementedHostServiceServer) KVDelete(context.Context, *KVDeleteRequest) (*emptypb.Empty, error)
func (UnimplementedHostServiceServer) KVGet ¶
func (UnimplementedHostServiceServer) KVGet(context.Context, *KVGetRequest) (*KVGetResponse, error)
func (UnimplementedHostServiceServer) KVSet ¶
func (UnimplementedHostServiceServer) KVSet(context.Context, *KVSetRequest) (*emptypb.Empty, error)
func (UnimplementedHostServiceServer) Log ¶
func (UnimplementedHostServiceServer) Log(context.Context, *LogRequest) (*emptypb.Empty, error)
type UnimplementedPluginServiceServer ¶
type UnimplementedPluginServiceServer struct{}
UnimplementedPluginServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedPluginServiceServer) AbilityCall ¶
func (UnimplementedPluginServiceServer) AbilityCall(context.Context, *CallRequest) (*CallResponse, error)
func (UnimplementedPluginServiceServer) Command ¶
func (UnimplementedPluginServiceServer) Command(context.Context, *CommandRequest) (*CommandResponse, error)
func (UnimplementedPluginServiceServer) Form ¶
func (UnimplementedPluginServiceServer) Form(context.Context, *FormRequest) (*FormResponse, error)
func (UnimplementedPluginServiceServer) Help ¶
func (UnimplementedPluginServiceServer) Help(context.Context, *emptypb.Empty) (*HelpResponse, error)
func (UnimplementedPluginServiceServer) Init ¶
func (UnimplementedPluginServiceServer) Init(context.Context, *InitRequest) (*InitResponse, error)
func (UnimplementedPluginServiceServer) IsReady ¶
func (UnimplementedPluginServiceServer) IsReady(context.Context, *emptypb.Empty) (*IsReadyResponse, error)
func (UnimplementedPluginServiceServer) OAuthCallback ¶
func (UnimplementedPluginServiceServer) OAuthCallback(context.Context, *OAuthCallbackRequest) (*CallResponse, error)
func (UnimplementedPluginServiceServer) Rules ¶
func (UnimplementedPluginServiceServer) Rules(context.Context, *emptypb.Empty) (*RulesResponse, error)
func (UnimplementedPluginServiceServer) WebhookConvert ¶
func (UnimplementedPluginServiceServer) WebhookConvert(context.Context, *WebhookConvertRequest) (*CallResponse, error)
type UnsafeHostServiceServer ¶
type UnsafeHostServiceServer interface {
// contains filtered or unexported methods
}
UnsafeHostServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HostServiceServer will result in compilation errors.
type UnsafePluginServiceServer ¶
type UnsafePluginServiceServer interface {
// contains filtered or unexported methods
}
UnsafePluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginServiceServer will result in compilation errors.
type WebhookConvertRequest ¶
type WebhookConvertRequest struct {
Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
// contains filtered or unexported fields
}
func (*WebhookConvertRequest) Descriptor
deprecated
func (*WebhookConvertRequest) Descriptor() ([]byte, []int)
Deprecated: Use WebhookConvertRequest.ProtoReflect.Descriptor instead.
func (*WebhookConvertRequest) GetPayload ¶
func (x *WebhookConvertRequest) GetPayload() []byte
func (*WebhookConvertRequest) ProtoMessage ¶
func (*WebhookConvertRequest) ProtoMessage()
func (*WebhookConvertRequest) ProtoReflect ¶
func (x *WebhookConvertRequest) ProtoReflect() protoreflect.Message
func (*WebhookConvertRequest) Reset ¶
func (x *WebhookConvertRequest) Reset()
func (*WebhookConvertRequest) String ¶
func (x *WebhookConvertRequest) String() string