integrationplugin

package
v0.54.1 Latest Latest
Warning

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

Go to latest
Published: Mar 29, 2024 License: BSD-3-Clause Imports: 12 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterIntegrationPluginServer

func RegisterIntegrationPluginServer(s *grpc.Server, srv IntegrationPluginServer)

func Start

Types

type Common

type Common struct {
	grpcplugin.Common
	HTTPPort int32
}

func (*Common) WorkerHTTPPort

func (c *Common) WorkerHTTPPort(_ context.Context, q *WorkerHTTPPortQuery) (*empty.Empty, error)

type IntegrationPluginClient

type IntegrationPluginClient interface {
	Manifest(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IntegrationPluginManifest, error)
	Run(ctx context.Context, in *RunQuery, opts ...grpc.CallOption) (*RunResult, error)
	WorkerHTTPPort(ctx context.Context, in *WorkerHTTPPortQuery, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Stop(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

IntegrationPluginClient is the client API for IntegrationPlugin service.

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

func Client

func Client(ctx context.Context, socket string) (IntegrationPluginClient, error)

type IntegrationPluginManifest

type IntegrationPluginManifest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Author               string   `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IntegrationPluginManifest) Descriptor

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

func (*IntegrationPluginManifest) GetAuthor

func (m *IntegrationPluginManifest) GetAuthor() string

func (*IntegrationPluginManifest) GetDescription

func (m *IntegrationPluginManifest) GetDescription() string

func (*IntegrationPluginManifest) GetName

func (m *IntegrationPluginManifest) GetName() string

func (*IntegrationPluginManifest) GetVersion

func (m *IntegrationPluginManifest) GetVersion() string

func (*IntegrationPluginManifest) ProtoMessage

func (*IntegrationPluginManifest) ProtoMessage()

func (*IntegrationPluginManifest) Reset

func (m *IntegrationPluginManifest) Reset()

func (*IntegrationPluginManifest) String

func (m *IntegrationPluginManifest) String() string

func (*IntegrationPluginManifest) XXX_DiscardUnknown

func (m *IntegrationPluginManifest) XXX_DiscardUnknown()

func (*IntegrationPluginManifest) XXX_Marshal

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

func (*IntegrationPluginManifest) XXX_Merge

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

func (*IntegrationPluginManifest) XXX_Size

func (m *IntegrationPluginManifest) XXX_Size() int

func (*IntegrationPluginManifest) XXX_Unmarshal

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

type IntegrationPluginServer

type IntegrationPluginServer interface {
	Manifest(context.Context, *emptypb.Empty) (*IntegrationPluginManifest, error)
	Run(context.Context, *RunQuery) (*RunResult, error)
	WorkerHTTPPort(context.Context, *WorkerHTTPPortQuery) (*emptypb.Empty, error)
	Stop(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
}

IntegrationPluginServer is the server API for IntegrationPlugin service.

type RunQuery

type RunQuery struct {
	Options              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RunQuery) Descriptor

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

func (*RunQuery) GetOptions

func (m *RunQuery) GetOptions() map[string]string

func (*RunQuery) ProtoMessage

func (*RunQuery) ProtoMessage()

func (*RunQuery) Reset

func (m *RunQuery) Reset()

func (*RunQuery) String

func (m *RunQuery) String() string

func (*RunQuery) XXX_DiscardUnknown

func (m *RunQuery) XXX_DiscardUnknown()

func (*RunQuery) XXX_Marshal

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

func (*RunQuery) XXX_Merge

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

func (*RunQuery) XXX_Size

func (m *RunQuery) XXX_Size() int

func (*RunQuery) XXX_Unmarshal

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

type RunResult

type RunResult struct {
	Status               string            `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Details              string            `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	Outputs              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RunResult) Descriptor

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

func (*RunResult) GetDetails

func (m *RunResult) GetDetails() string

func (*RunResult) GetOutputs

func (m *RunResult) GetOutputs() map[string]string

func (*RunResult) GetStatus

func (m *RunResult) GetStatus() string

func (*RunResult) ProtoMessage

func (*RunResult) ProtoMessage()

func (*RunResult) Reset

func (m *RunResult) Reset()

func (*RunResult) String

func (m *RunResult) String() string

func (*RunResult) XXX_DiscardUnknown

func (m *RunResult) XXX_DiscardUnknown()

func (*RunResult) XXX_Marshal

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

func (*RunResult) XXX_Merge

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

func (*RunResult) XXX_Size

func (m *RunResult) XXX_Size() int

func (*RunResult) XXX_Unmarshal

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

type UnimplementedIntegrationPluginServer

type UnimplementedIntegrationPluginServer struct {
}

UnimplementedIntegrationPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedIntegrationPluginServer) Manifest

func (*UnimplementedIntegrationPluginServer) Run

func (*UnimplementedIntegrationPluginServer) Stop

func (*UnimplementedIntegrationPluginServer) WorkerHTTPPort

type WorkerHTTPPortQuery

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

func (*WorkerHTTPPortQuery) Descriptor

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

func (*WorkerHTTPPortQuery) GetPort

func (m *WorkerHTTPPortQuery) GetPort() int32

func (*WorkerHTTPPortQuery) ProtoMessage

func (*WorkerHTTPPortQuery) ProtoMessage()

func (*WorkerHTTPPortQuery) Reset

func (m *WorkerHTTPPortQuery) Reset()

func (*WorkerHTTPPortQuery) String

func (m *WorkerHTTPPortQuery) String() string

func (*WorkerHTTPPortQuery) XXX_DiscardUnknown

func (m *WorkerHTTPPortQuery) XXX_DiscardUnknown()

func (*WorkerHTTPPortQuery) XXX_Marshal

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

func (*WorkerHTTPPortQuery) XXX_Merge

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

func (*WorkerHTTPPortQuery) XXX_Size

func (m *WorkerHTTPPortQuery) XXX_Size() int

func (*WorkerHTTPPortQuery) XXX_Unmarshal

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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