job

Documentation

Index

• func WithBatchPlugin(srv batchpb.BatchServer) nitricJobServerOption
• func WithKvStorePlugin(srv kvstorepb.KvStoreServer) nitricJobServerOption
• func WithQueuePlugin(srv queuespb.QueuesServer) nitricJobServerOption
• func WithSecretsPlugin(srv secretspb.SecretManagerServer) nitricJobServerOption
• func WithSqlPlugin(srv sqlpb.SqlServer) nitricJobServerOption
• func WithStoragePlugin(srv storagepb.StorageServer) nitricJobServerOption
• func WithTopicPlugin(srv topicspb.TopicsServer) nitricJobServerOption
• func WithWebsocketPlugin(srv websocketspb.WebsocketServer) nitricJobServerOption
• type NitricJobServer
  • func NewJobServer(cmd string, options ...nitricJobServerOption) *NitricJobServer
  • func (j *NitricJobServer) Run() error

Functions

func WithBatchPlugin

func WithBatchPlugin(srv batchpb.BatchServer) nitricJobServerOption

func WithKvStorePlugin

func WithKvStorePlugin(srv kvstorepb.KvStoreServer) nitricJobServerOption

func WithQueuePlugin

func WithQueuePlugin(srv queuespb.QueuesServer) nitricJobServerOption

func WithSecretsPlugin

func WithSecretsPlugin(srv secretspb.SecretManagerServer) nitricJobServerOption

func WithSqlPlugin

func WithSqlPlugin(srv sqlpb.SqlServer) nitricJobServerOption

func WithStoragePlugin

func WithStoragePlugin(srv storagepb.StorageServer) nitricJobServerOption

func WithTopicPlugin

func WithTopicPlugin(srv topicspb.TopicsServer) nitricJobServerOption

func WithWebsocketPlugin

func WithWebsocketPlugin(srv websocketspb.WebsocketServer) nitricJobServerOption

Types

type NitricJobServer

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

NitricJobServer is a membrane for job Created as a separate membrane type to avoid overloading the service membrane

func NewJobServer

func NewJobServer(cmd string, options ...nitricJobServerOption) *NitricJobServer

func (*NitricJobServer) Run

func (j *NitricJobServer) Run() error