grpc

Documentation

Index

• Variables
• func New(c *conf.RPCServerConfig) *grpc.Server
• func NewClient(c *conf.Config) types.GrpcClient
• type Client
  • func (c *Client) Manager() pb.JobManagerClient
  • func (c *Client) PubSub() pb.PubSubClient
  • func (c *Client) Resource() pb.ResourcesManagerClient
  • func (c *Client) Rule() pb.RuleActionClient
• type JobManagerClient
• type PubSubClient
• type ResourcesManagerClient
• type RuleActionClient

Variables

var MaxCallRecvMsgSize = grpc.MaxCallRecvMsgSize

Functions

func New

func New(c *conf.RPCServerConfig) *grpc.Server

func NewClient

func NewClient(c *conf.Config) types.GrpcClient

Types

type Client

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

func (*Client) Manager

func (c *Client) Manager() pb.JobManagerClient

func (*Client) PubSub

func (c *Client) PubSub() pb.PubSubClient

func (*Client) Resource

func (c *Client) Resource() pb.ResourcesManagerClient

func (*Client) Rule

func (c *Client) Rule() pb.RuleActionClient

type JobManagerClient

type JobManagerClient = pb.JobManagerClient

type PubSubClient

type PubSubClient = pb.PubSubClient

type ResourcesManagerClient

type ResourcesManagerClient = pb.ResourcesManagerClient

type RuleActionClient

type RuleActionClient = pb.RuleActionClient