daemon

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2018 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDaemonServer 

func RegisterDaemonServer(s *grpc.Server, srv DaemonServer)

Types

type DaemonClient 

type DaemonClient interface {
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
}

DaemonClient is the client API for Daemon service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDaemonClient 

func NewDaemonClient(cc *grpc.ClientConn) DaemonClient

type DaemonServer 

type DaemonServer interface {
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
	Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)
}

DaemonServer is the server API for Daemon service.

type Server 

type Server struct {
	// Termination is populated with requests from clients invoking the shutdown
	// method over RPC. It can be ignored by daemon host processes wishing to
	// ignore temination requests originating from clients. The channel is
	// buffered and non-blocking, so it doesn't need to be serviced by the
	// daemon host-process at all - additional incoming shutdown requests will
	// just bounce off once the channel is populated. We do this, instead of
	// closing the channel, because we can't close the channel multiple times.
	Termination chan struct{}
	// contains filtered or unexported fields
}

Server provides an implementation of the Daemon service.

func New 

func New() *Server

New creates an instance of the daemon server.

func (*Server) Shutdown 

func (s *Server) Shutdown()

Shutdown gracefully shuts down server resources.

func (*Server) Terminate added in v0.6.0 

func (s *Server) Terminate(_ context.Context, _ *TerminateRequest) (*TerminateResponse, error)

Terminate requests daemon termination.

func (*Server) Version 

func (s *Server) Version(_ context.Context, _ *VersionRequest) (*VersionResponse, error)

Version provides version information.

type TerminateRequest added in v0.6.0 

type TerminateRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TerminateRequest) Descriptor added in v0.6.0 

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

func (*TerminateRequest) ProtoMessage added in v0.6.0 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) Reset added in v0.6.0 

func (m *TerminateRequest) Reset()

func (*TerminateRequest) String added in v0.6.0 

func (m *TerminateRequest) String() string

func (*TerminateRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *TerminateRequest) XXX_DiscardUnknown()

func (*TerminateRequest) XXX_Marshal added in v0.6.0 

func (m *TerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateRequest) XXX_Merge added in v0.6.0 

func (dst *TerminateRequest) XXX_Merge(src proto.Message)

func (*TerminateRequest) XXX_Size added in v0.6.0 

func (m *TerminateRequest) XXX_Size() int

func (*TerminateRequest) XXX_Unmarshal added in v0.6.0 

func (m *TerminateRequest) XXX_Unmarshal(b []byte) error

type TerminateResponse added in v0.6.0 

type TerminateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TerminateResponse) Descriptor added in v0.6.0 

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

func (*TerminateResponse) ProtoMessage added in v0.6.0 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) Reset added in v0.6.0 

func (m *TerminateResponse) Reset()

func (*TerminateResponse) String added in v0.6.0 

func (m *TerminateResponse) String() string

func (*TerminateResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *TerminateResponse) XXX_DiscardUnknown()

func (*TerminateResponse) XXX_Marshal added in v0.6.0 

func (m *TerminateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateResponse) XXX_Merge added in v0.6.0 

func (dst *TerminateResponse) XXX_Merge(src proto.Message)

func (*TerminateResponse) XXX_Size added in v0.6.0 

func (m *TerminateResponse) XXX_Size() int

func (*TerminateResponse) XXX_Unmarshal added in v0.6.0 

func (m *TerminateResponse) XXX_Unmarshal(b []byte) error

type VersionRequest 

type VersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

func (*VersionRequest) XXX_DiscardUnknown 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal 

func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionRequest) XXX_Merge 

func (dst *VersionRequest) XXX_Merge(src proto.Message)

func (*VersionRequest) XXX_Size 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal 

func (m *VersionRequest) XXX_Unmarshal(b []byte) error

type VersionResponse 

type VersionResponse struct {
	// TODO: Should we encapsulate these inside a Version message type, perhaps
	// in the mutagen package?
	Major                uint64   `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor                uint64   `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	Patch                uint64   `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetMajor 

func (m *VersionResponse) GetMajor() uint64

func (*VersionResponse) GetMinor 

func (m *VersionResponse) GetMinor() uint64

func (*VersionResponse) GetPatch 

func (m *VersionResponse) GetPatch() uint64

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionResponse) XXX_Merge 

func (dst *VersionResponse) XXX_Merge(src proto.Message)

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

func (m *VersionResponse) XXX_Unmarshal(b []byte) error

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.