Help us shape the future of Go! Take the 2026 Go Developer Survey

integrationplugin

package
v0.57.0 Latest Latest
Warning

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

Go to latest
Published: Apr 15, 2026 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