client

Documentation

Index

• type Client
  • func NewClient(host string) (Client, error)
• type FluxionClient
  • func (c *FluxionClient) Cancel(ctx context.Context, in *pb.CancelRequest, opts ...grpc.CallOption) (*pb.CancelResponse, error)
  • func (c *FluxionClient) Close() error
  • func (c *FluxionClient) Connected() bool
  • func (c *FluxionClient) GetHost() string
  • func (c *FluxionClient) Init(ctx context.Context, in *pb.InitRequest, opts ...grpc.CallOption) (*pb.InitResponse, error)
  • func (c *FluxionClient) Match(ctx context.Context, in *pb.MatchRequest, opts ...grpc.CallOption) (*pb.MatchResponse, error)

Types

type Client

type Client interface {
	Match(ctx context.Context, in *pb.MatchRequest, opts ...grpc.CallOption) (*pb.MatchResponse, error)
	Cancel(ctx context.Context, in *pb.CancelRequest, opts ...grpc.CallOption) (*pb.CancelResponse, error)
	Init(ctx context.Context, in *pb.InitRequest, opts ...grpc.CallOption) (*pb.InitResponse, error)
}

Client interface defines functions required for a valid client

func NewClient

func NewClient(host string) (Client, error)

NewClient creates a new FluxionClient

type FluxionClient

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

FluxionClient interacts with Fluxion

func (*FluxionClient) Cancel

func (c *FluxionClient) Cancel(ctx context.Context, in *pb.CancelRequest, opts ...grpc.CallOption) (*pb.CancelResponse, error)

Cancel a job

func (*FluxionClient) Close

func (c *FluxionClient) Close() error

Close closes the created resources (e.g. connection).

func (*FluxionClient) Connected

func (c *FluxionClient) Connected() bool

Connected returns true if we are connected and the connection is ready

func (*FluxionClient) GetHost

func (c *FluxionClient) GetHost() string

GetHost returns the private hostn name

func (*FluxionClient) Init

func (c *FluxionClient) Init(ctx context.Context, in *pb.InitRequest, opts ...grpc.CallOption) (*pb.InitResponse, error)

Init the fluxion nodes

func (*FluxionClient) Match

func (c *FluxionClient) Match(ctx context.Context, in *pb.MatchRequest, opts ...grpc.CallOption) (*pb.MatchResponse, error)