publisher

package
v3.2.0 Latest Latest
Warning

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

 Go to latest Published: May 17, 2022 License: MIT Imports: 9 Imported by: 1

Documentation

Index

Constants

View Source 
const PluginName = "publisher"

Variables

View Source 
var File_pkg_publisher_publisher_proto protoreflect.FileDescriptor
View Source 
var PublisherPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "PublisherPlugin",
	HandlerType: (*PublisherPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _PublisherPlugin_Init_Handler,
		},
		{
			MethodName: "Name",
			Handler:    _PublisherPlugin_Name_Handler,
		},
		{
			MethodName: "Version",
			Handler:    _PublisherPlugin_Version_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _PublisherPlugin_Publish_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/publisher/publisher.proto",
}

PublisherPlugin_ServiceDesc is the grpc.ServiceDesc for PublisherPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPublisherPluginServer 

func RegisterPublisherPluginServer(s grpc.ServiceRegistrar, srv PublisherPluginServer)

Types

type Publisher 

type Publisher interface {
	Init(map[string]string) error
	Name() string
	Version() string
	Publish(newRelease string) error
}

type PublisherClient 

type PublisherClient struct {
	Impl PublisherPluginClient
}

func (*PublisherClient) Init 

func (c *PublisherClient) Init(m map[string]string) error

func (*PublisherClient) Name 

func (c *PublisherClient) Name() string

func (*PublisherClient) Publish 

func (c *PublisherClient) Publish(newRelease string) error

func (*PublisherClient) Version 

func (c *PublisherClient) Version() string

type PublisherInit 

type PublisherInit struct {
	// contains filtered or unexported fields
}

func (*PublisherInit) Descriptor deprecated 

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

Deprecated: Use PublisherInit.ProtoReflect.Descriptor instead.

func (*PublisherInit) ProtoMessage 

func (*PublisherInit) ProtoMessage()

func (*PublisherInit) ProtoReflect 

func (x *PublisherInit) ProtoReflect() protoreflect.Message

func (*PublisherInit) Reset 

func (x *PublisherInit) Reset()

func (*PublisherInit) String 

func (x *PublisherInit) String() string

type PublisherInit_Request 

type PublisherInit_Request struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PublisherInit_Request) Descriptor deprecated 

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

Deprecated: Use PublisherInit_Request.ProtoReflect.Descriptor instead.

func (*PublisherInit_Request) GetConfig 

func (x *PublisherInit_Request) GetConfig() map[string]string

func (*PublisherInit_Request) ProtoMessage 

func (*PublisherInit_Request) ProtoMessage()

func (*PublisherInit_Request) ProtoReflect 

func (x *PublisherInit_Request) ProtoReflect() protoreflect.Message

func (*PublisherInit_Request) Reset 

func (x *PublisherInit_Request) Reset()

func (*PublisherInit_Request) String 

func (x *PublisherInit_Request) String() string

type PublisherInit_Response 

type PublisherInit_Response struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PublisherInit_Response) Descriptor deprecated 

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

Deprecated: Use PublisherInit_Response.ProtoReflect.Descriptor instead.

func (*PublisherInit_Response) GetError 

func (x *PublisherInit_Response) GetError() string

func (*PublisherInit_Response) ProtoMessage 

func (*PublisherInit_Response) ProtoMessage()

func (*PublisherInit_Response) ProtoReflect 

func (x *PublisherInit_Response) ProtoReflect() protoreflect.Message

func (*PublisherInit_Response) Reset 

func (x *PublisherInit_Response) Reset()

func (*PublisherInit_Response) String 

func (x *PublisherInit_Response) String() string

type PublisherName 

type PublisherName struct {
	// contains filtered or unexported fields
}

func (*PublisherName) Descriptor deprecated 

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

Deprecated: Use PublisherName.ProtoReflect.Descriptor instead.

func (*PublisherName) ProtoMessage 

func (*PublisherName) ProtoMessage()

func (*PublisherName) ProtoReflect 

func (x *PublisherName) ProtoReflect() protoreflect.Message

func (*PublisherName) Reset 

func (x *PublisherName) Reset()

func (*PublisherName) String 

func (x *PublisherName) String() string

type PublisherName_Request 

type PublisherName_Request struct {
	// contains filtered or unexported fields
}

func (*PublisherName_Request) Descriptor deprecated 

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

Deprecated: Use PublisherName_Request.ProtoReflect.Descriptor instead.

func (*PublisherName_Request) ProtoMessage 

func (*PublisherName_Request) ProtoMessage()

func (*PublisherName_Request) ProtoReflect 

func (x *PublisherName_Request) ProtoReflect() protoreflect.Message

func (*PublisherName_Request) Reset 

func (x *PublisherName_Request) Reset()

func (*PublisherName_Request) String 

func (x *PublisherName_Request) String() string

type PublisherName_Response 

type PublisherName_Response struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PublisherName_Response) Descriptor deprecated 

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

Deprecated: Use PublisherName_Response.ProtoReflect.Descriptor instead.

func (*PublisherName_Response) GetName 

func (x *PublisherName_Response) GetName() string

func (*PublisherName_Response) ProtoMessage 

func (*PublisherName_Response) ProtoMessage()

func (*PublisherName_Response) ProtoReflect 

func (x *PublisherName_Response) ProtoReflect() protoreflect.Message

func (*PublisherName_Response) Reset 

func (x *PublisherName_Response) Reset()

func (*PublisherName_Response) String 

func (x *PublisherName_Response) String() string

type PublisherPluginClient 

type PublisherPluginClient interface {
	Init(ctx context.Context, in *PublisherInit_Request, opts ...grpc.CallOption) (*PublisherInit_Response, error)
	Name(ctx context.Context, in *PublisherName_Request, opts ...grpc.CallOption) (*PublisherName_Response, error)
	Version(ctx context.Context, in *PublisherVersion_Request, opts ...grpc.CallOption) (*PublisherVersion_Response, error)
	Publish(ctx context.Context, in *PublisherPublish_Request, opts ...grpc.CallOption) (*PublisherPublish_Response, error)
}

PublisherPluginClient is the client API for PublisherPlugin 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.

func NewPublisherPluginClient 

func NewPublisherPluginClient(cc grpc.ClientConnInterface) PublisherPluginClient

type PublisherPluginServer 

type PublisherPluginServer interface {
	Init(context.Context, *PublisherInit_Request) (*PublisherInit_Response, error)
	Name(context.Context, *PublisherName_Request) (*PublisherName_Response, error)
	Version(context.Context, *PublisherVersion_Request) (*PublisherVersion_Response, error)
	Publish(context.Context, *PublisherPublish_Request) (*PublisherPublish_Response, error)
	// contains filtered or unexported methods
}

PublisherPluginServer is the server API for PublisherPlugin service. All implementations must embed UnimplementedPublisherPluginServer for forward compatibility

type PublisherPublish 

type PublisherPublish struct {
	// contains filtered or unexported fields
}

func (*PublisherPublish) Descriptor deprecated 

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

Deprecated: Use PublisherPublish.ProtoReflect.Descriptor instead.

func (*PublisherPublish) ProtoMessage 

func (*PublisherPublish) ProtoMessage()

func (*PublisherPublish) ProtoReflect 

func (x *PublisherPublish) ProtoReflect() protoreflect.Message

func (*PublisherPublish) Reset 

func (x *PublisherPublish) Reset()

func (*PublisherPublish) String 

func (x *PublisherPublish) String() string

type PublisherPublish_Request 

type PublisherPublish_Request struct {
	NewRelease string `protobuf:"bytes,1,opt,name=new_release,json=newRelease,proto3" json:"new_release,omitempty"`
	// contains filtered or unexported fields
}

func (*PublisherPublish_Request) Descriptor deprecated 

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

Deprecated: Use PublisherPublish_Request.ProtoReflect.Descriptor instead.

func (*PublisherPublish_Request) GetNewRelease 

func (x *PublisherPublish_Request) GetNewRelease() string

func (*PublisherPublish_Request) ProtoMessage 

func (*PublisherPublish_Request) ProtoMessage()

func (*PublisherPublish_Request) ProtoReflect 

func (x *PublisherPublish_Request) ProtoReflect() protoreflect.Message

func (*PublisherPublish_Request) Reset 

func (x *PublisherPublish_Request) Reset()

func (*PublisherPublish_Request) String 

func (x *PublisherPublish_Request) String() string

type PublisherPublish_Response 

type PublisherPublish_Response struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PublisherPublish_Response) Descriptor deprecated 

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

Deprecated: Use PublisherPublish_Response.ProtoReflect.Descriptor instead.

func (*PublisherPublish_Response) GetError 

func (x *PublisherPublish_Response) GetError() string

func (*PublisherPublish_Response) ProtoMessage 

func (*PublisherPublish_Response) ProtoMessage()

func (*PublisherPublish_Response) ProtoReflect 

func (x *PublisherPublish_Response) ProtoReflect() protoreflect.Message

func (*PublisherPublish_Response) Reset 

func (x *PublisherPublish_Response) Reset()

func (*PublisherPublish_Response) String 

func (x *PublisherPublish_Response) String() string

type PublisherServer 

type PublisherServer struct {
	Impl Publisher
	UnimplementedPublisherPluginServer
}

func (*PublisherServer) Init 

func (p *PublisherServer) Init(ctx context.Context, request *PublisherInit_Request) (*PublisherInit_Response, error)

func (*PublisherServer) Name 

func (p *PublisherServer) Name(ctx context.Context, request *PublisherName_Request) (*PublisherName_Response, error)

func (*PublisherServer) Publish 

func (p *PublisherServer) Publish(ctx context.Context, request *PublisherPublish_Request) (*PublisherPublish_Response, error)

func (*PublisherServer) Version 

func (p *PublisherServer) Version(ctx context.Context, request *PublisherVersion_Request) (*PublisherVersion_Response, error)

type PublisherVersion 

type PublisherVersion struct {
	// contains filtered or unexported fields
}

func (*PublisherVersion) Descriptor deprecated 

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

Deprecated: Use PublisherVersion.ProtoReflect.Descriptor instead.

func (*PublisherVersion) ProtoMessage 

func (*PublisherVersion) ProtoMessage()

func (*PublisherVersion) ProtoReflect 

func (x *PublisherVersion) ProtoReflect() protoreflect.Message

func (*PublisherVersion) Reset 

func (x *PublisherVersion) Reset()

func (*PublisherVersion) String 

func (x *PublisherVersion) String() string

type PublisherVersion_Request 

type PublisherVersion_Request struct {
	// contains filtered or unexported fields
}

func (*PublisherVersion_Request) Descriptor deprecated 

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

Deprecated: Use PublisherVersion_Request.ProtoReflect.Descriptor instead.

func (*PublisherVersion_Request) ProtoMessage 

func (*PublisherVersion_Request) ProtoMessage()

func (*PublisherVersion_Request) ProtoReflect 

func (x *PublisherVersion_Request) ProtoReflect() protoreflect.Message

func (*PublisherVersion_Request) Reset 

func (x *PublisherVersion_Request) Reset()

func (*PublisherVersion_Request) String 

func (x *PublisherVersion_Request) String() string

type PublisherVersion_Response 

type PublisherVersion_Response struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*PublisherVersion_Response) Descriptor deprecated 

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

Deprecated: Use PublisherVersion_Response.ProtoReflect.Descriptor instead.

func (*PublisherVersion_Response) GetVersion 

func (x *PublisherVersion_Response) GetVersion() string

func (*PublisherVersion_Response) ProtoMessage 

func (*PublisherVersion_Response) ProtoMessage()

func (*PublisherVersion_Response) ProtoReflect 

func (x *PublisherVersion_Response) ProtoReflect() protoreflect.Message

func (*PublisherVersion_Response) Reset 

func (x *PublisherVersion_Response) Reset()

func (*PublisherVersion_Response) String 

func (x *PublisherVersion_Response) String() string

type UnimplementedPublisherPluginServer 

type UnimplementedPublisherPluginServer struct {
}

UnimplementedPublisherPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedPublisherPluginServer) Init 

func (UnimplementedPublisherPluginServer) Init(context.Context, *PublisherInit_Request) (*PublisherInit_Response, error)

func (UnimplementedPublisherPluginServer) Name 

func (UnimplementedPublisherPluginServer) Name(context.Context, *PublisherName_Request) (*PublisherName_Response, error)

func (UnimplementedPublisherPluginServer) Publish 

func (UnimplementedPublisherPluginServer) Publish(context.Context, *PublisherPublish_Request) (*PublisherPublish_Response, error)

func (UnimplementedPublisherPluginServer) Version 

func (UnimplementedPublisherPluginServer) Version(context.Context, *PublisherVersion_Request) (*PublisherVersion_Response, error)

type UnsafePublisherPluginServer 

type UnsafePublisherPluginServer interface {
	// contains filtered or unexported methods
}

UnsafePublisherPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PublisherPluginServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.