server

Documentation

Index

• Variables
• func Command() (cli.Command, error)
• func WithCompiler(c *lib.Compiler) func(*ProtoconfMutationServer)
• type MutationServerOption
• type ProtoconfMutationServer
  • func NewProtoconfMutationServer(protoconfRoot string, opts ...MutationServerOption) *ProtoconfMutationServer
  • func (s *ProtoconfMutationServer) GenReflectionUI(ctx context.Context, rpcServer *grpc.Server, httpServer *http.Server) error
  • func (s *ProtoconfMutationServer) Init(rpcServer *grpc.Server)
  • func (s *ProtoconfMutationServer) MutateConfig(ctx context.Context, in *protoconf_pb.ConfigMutationRequest) (*protoconf_pb.ConfigMutationResponse, error)
  • func (s *ProtoconfMutationServer) Put(ctx context.Context, in *dynamicpb.Message) (proto.Message, error)
  • func (s *ProtoconfMutationServer) ReportProgress(ctx context.Context, in *protoconf_pb.ConfigMutationResponse) (*protoconf_pb.ConfigMutationResponse, error)
  • func (s *ProtoconfMutationServer) StoreReport(id string, ...)

Variables

var (
	ErrPreMutationScriptError  = errors.New("error running pre-mutation script")
	ErrPostMutationScriptError = errors.New("error running post-mutation script")
	ErrInternalCompilerError   = errors.New("error compiling configs")
)

Functions

func Command

func Command() (cli.Command, error)

Command is a cli.CommandFactory

func WithCompiler

func WithCompiler(c *lib.Compiler) func(*ProtoconfMutationServer)

Types

type MutationServerOption

type MutationServerOption func(*ProtoconfMutationServer)

type ProtoconfMutationServer

type ProtoconfMutationServer struct {
	protoconf_pb.UnimplementedProtoconfMutationServiceServer
	protoconf_pb.UnimplementedProtoconfMutationReportServiceServer

	PreMutationScript  string
	PostMutationScript string
	// contains filtered or unexported fields
}

func NewProtoconfMutationServer

func NewProtoconfMutationServer(protoconfRoot string, opts ...MutationServerOption) *ProtoconfMutationServer

func (*ProtoconfMutationServer) GenReflectionUI

func (s *ProtoconfMutationServer) GenReflectionUI(ctx context.Context, rpcServer *grpc.Server, httpServer *http.Server) error

func (*ProtoconfMutationServer) Init

func (s *ProtoconfMutationServer) Init(rpcServer *grpc.Server)

func (*ProtoconfMutationServer) MutateConfig

func (s *ProtoconfMutationServer) MutateConfig(ctx context.Context, in *protoconf_pb.ConfigMutationRequest) (*protoconf_pb.ConfigMutationResponse, error)

func (*ProtoconfMutationServer) Put

func (s *ProtoconfMutationServer) Put(ctx context.Context, in *dynamicpb.Message) (proto.Message, error)

func (*ProtoconfMutationServer) ReportProgress

func (s *ProtoconfMutationServer) ReportProgress(ctx context.Context, in *protoconf_pb.ConfigMutationResponse) (*protoconf_pb.ConfigMutationResponse, error)

func (*ProtoconfMutationServer) StoreReport

func (s *ProtoconfMutationServer) StoreReport(id string, f func(*protoconf_pb.ConfigMutationResponse) *protoconf_pb.ConfigMutationResponse)