pb

package
v0.92.1 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2026 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
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

View Source
var File_pkg_plugin_grpc_proto_plugin_proto protoreflect.FileDescriptor
View Source
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)

View Source
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).

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.

type PluginServiceServer

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) GetConfig

func (UnimplementedHostServiceServer) HTTPRequest

func (UnimplementedHostServiceServer) KVDelete

func (UnimplementedHostServiceServer) KVGet

func (UnimplementedHostServiceServer) KVSet

func (UnimplementedHostServiceServer) Log

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) Bootstrap

func (UnimplementedPluginServiceServer) Command

func (UnimplementedPluginServiceServer) Form

func (UnimplementedPluginServiceServer) Help

func (UnimplementedPluginServiceServer) Init

func (UnimplementedPluginServiceServer) IsReady

func (UnimplementedPluginServiceServer) OAuthCallback

func (UnimplementedPluginServiceServer) Rules

func (UnimplementedPluginServiceServer) WebhookConvert

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL